platform/packages/core/example/json.dart
2024-09-24 21:04:57 -07:00

53 lines
1.2 KiB
Dart

import 'dart:async';
import 'dart:io';
import 'dart:isolate';
import 'package:platform_core/core.dart';
import 'package:platform_core/http.dart';
void main() async {
var x = 0;
var c = Completer();
var exit = ReceivePort();
var isolates = <Isolate>[];
exit.listen((_) {
if (++x >= 50) {
c.complete();
}
});
for (var i = 1; i < Platform.numberOfProcessors; i++) {
var isolate = await Isolate.spawn(serverMain, null);
isolates.add(isolate);
print('Spawned isolate #${i + 1}...');
isolate.addOnExitListener(exit.sendPort);
}
serverMain(null);
print('Protevus listening at http://localhost:3000');
await c.future;
}
void serverMain(_) async {
var app = Protevus();
var http =
ProtevusHttp.custom(app, startShared, useZone: false); // Run a cluster
app.get('/', (req, res) {
return res.serialize({
'foo': 'bar',
'one': [2, 'three'],
'bar': {'baz': 'quux'}
});
});
app.errorHandler = (e, req, res) {
print(e.message);
print(e.stackTrace);
};
var server = await http.startServer('127.0.0.1', 3000);
print('Listening at http://${server.address.address}:${server.port}');
}