package ipc_test | |
/* | |
func startRoamingServer() { | |
mgr := imanager.InternalNew(naming.FixedRoutingID(0x1111111)) | |
ns := newNamespace() | |
} | |
func TestRoamingListen(t *testing.T) { | |
r, err := rt.New() | |
if err != nil { | |
t.Errorf("unexpected error: %s", err) | |
} | |
publisher := config.CreateStream("test") | |
server, err := r.NewServer() | |
defer server.Stop() | |
if err != nil { | |
t.Errorf("unexpected error: %s", err) | |
} | |
server.RoamingListen(r.Publisher()) | |
server.Serve(nil) | |
} | |
*/ |