whereTypeIs method

Stream<ApiSignal> whereTypeIs(
  1. MSchemaRef type
)

Implementation

Stream<ApiSignal> whereTypeIs(MSchemaRef type) {
  if (this == null) return Stream.empty();
  return this!.where((signal) {
    if (signal is ApiUpdateSignal) {
      return signal.updatedKey.mtype == type;
    } else if (signal is ApiDeleteSignal) {
      return signal.deletedKey.mtype == type;
    } else if (signal is ApiCreateSignal) {
      return signal.newKey!.mtype == type;
    } else {
      return false;
    }
  });
}