Changeset View

Standalone View

Show All 39 Lines	class StreamJournalWriter(Generic[TValue]):

write_update = write_addition		write_update = write_addition

def write_additions(		def write_additions(
self, object_type: str, objects: List[TValue], privileged: bool = False		self, object_type: str, objects: List[TValue], privileged: bool = False
) -> None:		) -> None:
for object_ in objects:		for object_ in objects:
self.write_addition(object_type, object_, privileged)		self.write_addition(object_type, object_, privileged)

		def flush(self):
		self.output.flush()