call method

Implementation

Stream<Nip01Event> call() {
  return unverifiedStreamInput
      .flatMap(
        (event) => Stream.fromFuture(_verifyEvent(event)),
        maxConcurrent: maxConcurrent,
      )
      .where((event) => event?.validSig == true)
      .whereType<Nip01Event>() // filter nulls
      .shareReplay(maxSize: 1);
}