eric-sse 0.5.3.3

A lightweight message dispatcher based on SSE protocol data transfer objects format

The lightweight library for async messaging nobody expects.

Installation

pip install eric-sse

Features

• Send to one listener and broadcast
• SSE format was adopted by design, is order to make library suitable for such kind of model
• Sockets
• Callbacks
• [Experimental] Threading support for large data processing

Possible applications

• Message delivery mechanisms based on SSE
• Message queue processing (logging, etc)
• See https://github.com/laxertu/eric-api

Trivia

• Library name pretends to be a tribute to the following movie https://en.wikipedia.org/wiki/Looking_for_Eric

Documentation

• Overview
• Entities
  • AbstractChannel
    • AbstractChannel.add_listener()
    • AbstractChannel.broadcast()
    • AbstractChannel.deliver_next()
    • AbstractChannel.dispatch()
    • AbstractChannel.message_stream()
    • AbstractChannel.notify_end()
    • AbstractChannel.register_listener()
  • Message
  • MessageQueueListener
    • MessageQueueListener.on_message()
• Prefab channels and listeners
  • DataProcessingChannel
    • DataProcessingChannel.adapt()
    • DataProcessingChannel.process_queue()
  • SSEChannel
• Prefab servers
  • ChannelContainer
  • SocketServer
    • SocketServer.connect_callback()
    • SocketServer.shutdown()
    • SocketServer.start()
• Exceptions
  • InvalidChannelException
  • InvalidListenerException
  • InvalidMessageFormat
  • NoMessagesException
• Changelog
• Developers section