hprose / hprose-dart Goto Github PK

i use the demo code on a flutter demo to test push
await prosumer1.subscribe('test', (message) {
print('112233');
print(message);
print(message.toJson());
});
final r1 = prosumer2.push('hello', 'test');

but i view the log only get these
I/flutter (13244): Hm1{s2"id"u1}Cu+a1{s4"test"}z
I/flutter (13244): Rtz
I/flutter (13244): Hm1{s2"id"u1}Cu<z
I/flutter (13244): Hm1{s2"id"u2}Cs2">*"a2{s5"hello"s4"test"}z
I/flutter (13244): Rm1{s4"test"a1{c1"@"2{s4"data"s4"from"}o0{s5"hello"u2}}}z
I/flutter (13244): Rm1{u1t}z
I/flutter (13244): the result of push [{1: true}]
I/flutter (13244): Hm1{s2"id"u1}Cu<z
I/flutter (13244): Hm1{s2"id"u1}Cu-a1{s4"test"}z
I/flutter (13244): Rnz
I/flutter (13244): Rtz

dont get my log "112233"

hope for answer

null safe已经正式上线了。
hprose.dart里 rpc.dart 和core.dart 里的Service 命名冲突，导致测试通不过

hi,
I'm using Dart in Google app engine (via: https://pub.dev/packages/appengine).

When the code in my server.dart is looks like this

import 'dart:io';
import 'package:appengine/appengine.dart';
import 'package:hprose/rpc.dart';

requestHandler(HttpRequest request) {
  if (request.uri.path == "/rpc") {

    // HProse server code here 
    var service = new Service();
    service.addMethod(hello);

    //TODO:   how?
      service.bind( ???? )
      ...

  } else {
    request.response
      ..write('server ok')
      ..close();
  }
}

String hello(String name) {
  return 'hello $name';
}

main() async {
  await runAppEngine(requestHandler);
}

but I don't know how to bind the hprose handler within it's Method requestHandler(HttpRequest request)