You're Invited:Meet the Socket Team at BlackHat and DEF CON in Las Vegas, Aug 7-8.RSVP
Socket
Socket
Sign inDemoInstall

reactive-reference

Package Overview
Dependencies
Maintainers
1
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

reactive-reference

A collection of mini projects for a reactive programming approach


Maintainers
1

Readme

Reactive Reference

This is a collection of mini projects with the intent to have a more reactive programming approach in Python.

Event

A Producer/Subscriber library with Async capabilities.

Main Entities

EventStream

A stream of data that triggers subscribers on new events. It is structured with Domains in mind, meaning the data can be sent to every subscriber listening or specifically to the Domain of the Producer.

EventSubscriber

A listener to the data emitted by the EventStream. Can listen to multiple Domains at a time, but can only have 1 main Domain.

EventProducer

Producer will emit data to the stream triggering the Subscribers. The data sent via the producer will be encapsulated in an Event object which will be stored in the stream and spread across.

Key Points

  • Each Subscriber can adhere to a ReplayStrategy for late joining
  • Per design only one stream can exist (Singleton)
  • Subscribers can also listen to lifecycle events emitted by the stream

FAQs


Did you know?

Socket

Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.

Install

Related posts

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc