stream_validation_connector library

Classes

StreamValidationConnector<K, I>
Validation Connector, that subscribes on provided Stream

Extensions

StreamConnectorExtention on Stream<I>
Extension to create ValidationConnector from a Stream object