centrifuge 0.1.0

Dart client to communicate with Centrifuge and Centrifugo from Flutter and VM over dart:io WebSocket

Example

Examples:

• example\flutter_app simple chat application
• example\console simple console application

Usage

Create client:

import 'package:centrifuge/centrifuge.dart' as centrifuge;

final client = centrifuge.createClient(url);

Connect to server:

await client.connect();

Subscribe to channel:

final subscription = client.subscribe(channel);

subscription.publishStream.listen(onEvent);
subscription.joinStream.listen(onEvent);
subscription.leaveStream.listen(onEvent);

subscription.subscribeSuccessStream.listen(onEvent);
subscription.subscribeErrorStream.listen(onEvent);
subscription.unsubscribeStream.listen(onEvent);

Subscribe to private channel:

final privateSubscription = client.subscribe(channel, token: 'token');

Publish:

final output = jsonEncode({'input': message});
final data = utf8.encode(output);
await subscription.publish(data);

Checklist:

• connect to server using JSON protocol format
• connect to server using Protobuf protocol format
• connect with JWT
• connect with custom header
• support automatic reconnect in case of errors, network problems etc
• connect and disconnect events
• handle disconnect reason
• subscribe on channel and handle asynchronous Publications
• handle Join and Leave messages
• handle unsubscribe notifications
• handle subscribe error
• support publish, presence, presence stats and history methods
• send asynchronous messages to server
• handle asynchronous messages from server
• send RPC commands
• subscribe to private channels with JWT
• support connection JWT refresh
• support private channel subscription JWT refresh
• ping/pong to find broken connection
• support message recovery mechanism

Author

German Saprykin, [e-mail]