GenServer
Features
- End-to-end encryption
- Channel
- Reconnect
Class
- GenServer
- GenClient
- GenSocket
Data Flow
Usage
Server
import 'package:gen_server/gen_server.dart';
import 'package:gen_server/gen_socket.dart';
/* Usage & main function here */
Future<GenServer> launchServer() async {
var gen_server = GenServer(host: '0.0.0.0', port: 8080);
gen_server.onConnect((GenSocket gen_socket) {
gen_socket.sendMessage('This is a new message');
gen_socket.sendMessage('This is a new message - 1');
gen_socket.sendMessage('This is a new message - 2');
});
gen_server.onMessage((GenSocket gen_socket, String data) async {
gen_server.log('Message: $data');
await gen_socket.sendMessage('From server::::$data');
});
gen_server.onClose((GenSocket gen_socket) {
print("Socket closed.");
});
gen_server.start();
return gen_server;
}
Client
import 'package:gen_server/gen_client.dart';
import 'package:gen_server/gen_socket.dart';
/* Usage & main function here */
Future<GenClient> launchClient() async {
// connect to the socket server
var client = GenClient(host: '127.0.0.1', port: 8080);
client.onConnect(( GenSocket gen_socket) async {
await gen_socket.sendMessage('Hello');
await Future.delayed(Duration(milliseconds: 10));
await gen_socket.sendMessage('Anyone there?');
await Future.delayed(Duration(milliseconds: 10));
await gen_socket.sendMessage('Hi');
await Future.delayed(Duration(milliseconds: 10));
await gen_socket.sendMessage('Oh...');
await Future.delayed(Duration(milliseconds: 10));
await gen_socket.sendMessage('bye..');
// await gen_socket.disconnect();
});
client.onMessage((GenSocket gen_socket, String data) async {
client.log('Message: $data');
});
client.onClose((GenSocket gen_socket) async {
print("Socket closed.");
await Future.delayed(Duration(milliseconds: 100));
await gen_socket.reconnect();
});
await client.start();
return client;
}
void main() async {
var client = await launchClient();
}
Links
Author/Contributors
- Samick - created at 2022.05.17