stream_isolate 0.1.0 stream_isolate: ^0.1.0 copied to clipboard
An isolate wrapper for stream-powered intercommunication.
example/stream_isolate_example.dart
import 'dart:async';
import 'package:stream_isolate/stream_isolate.dart';
Future<void> wait(int ms) => Future.delayed(Duration(milliseconds: ms));
void main() async {
final streamIsolate =
await StreamIsolate.spawnBidirectional<String, int>(doWorkWithListener);
sendMessages(streamIsolate);
// final streamIsolate = await StreamIsolate.spawn<int>(doWork);
await for (final i in streamIsolate.stream) {
print('main: $i');
}
print('Done');
}
Stream<int> doWork(_) async* {
yield 0;
await wait(100);
yield 1;
await wait(100);
yield 2;
await wait(100);
yield 3;
await wait(100);
yield 4;
await wait(100);
yield 5;
}
Stream<int> doWorkWithError(_) async* {
yield 0;
await wait(100);
yield 1;
await wait(100);
throw StateError('error');
}
void sendMessages(BidirectionalStreamIsolate<String, int> isolate) async {
await wait(50);
isolate.send('a');
await wait(100);
isolate.send('b');
await wait(100);
isolate.send('c');
await wait(100);
isolate.send('d');
await wait(100);
isolate.send('e');
}
Stream<int> doWorkWithListener(Stream<String> inc, _) async* {
inc.listen((msg) => print('isolate: $msg'));
yield 0;
await wait(100);
yield 1;
await wait(100);
yield 2;
await wait(100);
yield 3;
await wait(100);
yield 4;
await wait(100);
yield 5;
}