call method

Stream<Nip01Event> call()

Implementation

Stream<Nip01Event> call() {
  return unverifiedStreamInput
      .asyncMap<Nip01Event>((data) async {
        final valid = await eventVerifier.verify(data);
        data.validSig = valid; // assign validity
        return data;
      })
      .where((event) => event.validSig == true) // Filter out invalid events
      .asBroadcastStream();
}