Utility classes and functions commonly used in DataSource integrations, such as efficiently observable Maps, and stream transformations.
com.caplin.integration.datasourcex.util.flow.FlowMap