- private ShardSnapshotCohort(final LocalHistoryIdentifier applyHistoryId, final ActorRef snapshotActor,
- final ShardDataTree store, final Logger log, final String logId) {
+ ShardSnapshotCohort(final InputOutputStreamFactory streamFactory, final LocalHistoryIdentifier applyHistoryId,
+ final ActorRef snapshotActor, final ShardDataTree store, final Logger log, final String logId) {
+ this.streamFactory = requireNonNull(streamFactory);