call method

Implementation

Stream<Nip01Event> call() {
  return unverifiedStreamInput
      .asyncMap<Nip01Event>((data) async {
        final valid = await eventVerifier.verify(data);
        data.validSig = valid; // assign validity

        if (!valid) {
          Logger.log
              .w('WARNING: Event with id ${data.id} has invalid signature');
        }

        return data;
      })
      .where((event) => event.validSig == true) // Filter out invalid events
      .asBroadcastStream();
}