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