eventflux 1.5.0-beta.1
eventflux: ^1.5.0-beta.1 copied to clipboard
Efficient handling of server-sent event streams with easy connectivity and data management.
EventFlux đ #
![](https://i.ibb.co/R4RcJVB/F.png)
EventFlux is a Dart package designed for efficient handling of server-sent event streams. It provides easy-to-use connectivity, data management, and robust error handling for real-time data applications. đ
Inspiration đĄ #
EventFlux was born from the inspiration I found in the flutter_client_sse
package by Pratik Baid. His work laid a great foundation, and I aimed to build upon it, adding my own twist to enhance SSE stream management with better features. đ ī¸
Why EventFlux? đ #
- Streamlined Connection Handling: Easy setup for connecting to event streams with support for both GET and POST requests. đ
- Auto-Reconnect Capability: Seamlessly maintains your connection, automatically reconnecting in case of any interruptions. đ
- Real-Time Data Management: Efficient processing and handling of real-time data streams. đ
- Error Handling: Robust mechanisms to manage connection interruptions and stream errors. đĄī¸
- Versatile Instance Creation: Offers both singleton and multi-instance options for tailored SSE connections. đ
- Customizable: Extendable to fit various use cases and custom implementations. â¨
EventFlux for Every Scenario đ #
![](https://i.ibb.co/99Rcx0R/flow-explanation.png)
Get Started in a Snap đĻ #
Add EventFlux to your Dart project's dependencies, and you're golden:
dependencies:
eventflux: ^1.5.0
How to Use (Spoiler: It's Super Easy) đ§ #
Here's a quick example to get you started:
The Simple Streamer â¨
Need just one SSE connection? It's a breeze with EventFlux! Perfect for when your app is dancing solo with a single SSE.
import 'package:eventflux/eventflux.dart';
void main() {
// Connect and start the magic!
EventFlux.instance.connect(
EventFluxConnectionType.get,
'https://example.com/events',
onSuccessCallback: (EventFluxResponse? response) {
response.stream?.listen((data) {
// Your data is now in the spotlight!
});
},
onError: (oops) {
// Oops! Time to handle those little hiccups.
},
autoReconnect: true // Keep the party going, automatically!
);
}
Supercharged đ
When your app just need a multiple parallel SSE connections, use this.
import 'package:eventflux/eventflux.dart';
void main() {
// Create separate EventFlux instances for each SSE connection
EventFlux e1 = EventFlux.spawn();
EventFlux e2 = EventFlux.spawn();
// First connection - firing up!
e1.connect(EventFluxConnectionType.get,
'https://example1.com/events',
onSuccessCallback: (EventFluxResponse? data) {
data.stream?.listen((data) {
// Your 1st Stream's data is being fetched!
});
},
onError: (oops) {
// Oops! Time to handle those little hiccups.
},
);
// Second connection - firing up!
e2.connect(EventFluxConnectionType.get,
'https://example2.com/events',
onSuccessCallback: (EventFluxResponse? data) {
data.stream?.listen((data) {
// Your 2nd Stream's data is also being fetched!
});
},
onError: (oops) {
// Oops! Time to handle those little hiccups.
},
autoReconnect: true // Keep the party going, automatically!
);
}
âšī¸ Remember to disconnect all instances when you are done with it to avoid memory leaks.
Need More Info? đ #
- EventFlux: Main class for managing event streams.
- EventFluxData: Data model for events received from the stream.
- EventFluxException: Custom exception handling for EventFlux operations.
- EventFluxResponse: Encapsulates the response from EventFlux operations.
- Enums:
EventFluxConnectionType
for specifying connection types andEventFluxStatus
for connection status.
For detailed documentation, please see the respective Dart files in the lib
folder.
EventFlux Class Documentation đ #
EventFlux
is a Dart class for managing server-sent event streams. It provides methods for connecting to, disconnecting from, and managing SSE streams.
connect
Connects to a server-sent event stream.
Parameter | Type | Description | Default |
---|---|---|---|
type |
EventFluxConnectionType |
The type of HTTP request (GET or POST). | - |
url |
String |
The URL of the SSE stream to connect to. | - |
header |
Map<String, String> |
HTTP headers for the request. | {'Accept': 'text/event-stream'} |
onConnectionClose |
Function()? |
Callback function triggered when the connection is closed. | - |
autoReconnect |
bool |
Whether to automatically reconnect on disconnection. | false |
onSuccessCallback |
Function(EventFluxResponse?) |
Callback invoked upon successful connection. | - |
onError |
Function(EventFluxException)? |
Callback for handling errors. | - |
body |
Map<String, dynamic>? |
Optional body for POST request types. | - |
disconnect
Disconnects from the SSE stream.
Parameter | Type | Description |
---|---|---|
- | - | This method has no parameters. |
Returns a Future<EventFluxStatus>
indicating the disconnection status.
spawn
Parameter | Type | Description |
---|---|---|
- | - | This method has no parameters. |
Returns a new instance of EventFlux
, this is useful for having multiple SSE connections.
Be a Part of the Adventure đ¤ #
Got ideas? Want to contribute? Jump aboard! Open an issue or send a pull request. Let's make EventFlux even more awesome together!
The Boring (but Important) Stuff đ #
Licensed under MIT - use it freely, but let's play nice and give credit where it's due!