[WIP]MagicOnion 2.0.0(-alpha), StreamingHub

[neuecc]

Currently available in NuGet, you can try it.
https://www.nuget.org/packages/MagicOnion/2.0.1-alpha

new feature StreamingHub is like SignalR or Socket.IO.
It can be handle bi-directional streaming easily.

// common(server/client) interfaces

public interface IMessageReceiver
{
    Task OnReceiveMessage(string senderUser, string message);
}

public interface IChatHub : IStreamingHub<IChatHub, IMessageReceiver>
{
    Task<Nil> JoinAsync(string userName, string roomName);
    Task<Nil> LeaveAsync();
    Task SendMessageAsync(string message);
}

// server impl

public class ChatHub : StreamingHubBase<IChatHub, IMessageReceiver>, IChatHub
{
    // insantiate per user connected and live while connecting.
    string userName;
    IGroup room;

    // return Task<T> wait server completed.
    public Task<Nil> JoinAsync(string userName, string roomName)
    {
        this.userName = userName;
        this.room = Group.Add("InMemoryRoom:" + roomName, this.Context);

        return NilTask;
    }

    // return Task is fire and forget(does not wait server completed).
    public async Task SendMessageAsync(string message)
    {
        // broadcast to connected group(same roomname members).
        await Broadcast(room).OnReceiveMessage(this.userName, message);
    }

    public async Task<Nil> LeaveAsync()
    {
        await BroadcastExceptSelf(room).OnReceiveMessage(userName, "SYSTEM_MESSAGE_LEAVE_USER");
        room.Remove(this.Context);

        return Nil.Default;
    }

    protected override ValueTask OnConnecting()
    {
        return CompletedTask; // you can hook connecting event.
    }

    protected override ValueTask OnDisconnected()
    {
        room?.Remove(this.Context); // remove from group.
        return CompletedTask;
    }
}

// client

public class ClientProgram : IMessageReceiver
{
    public async Task Start(string user, string room)
    {
        var channel = new Channel("localhost:12345", ChannelCredentials.Insecure);

        var client = StreamingHubClient.Connect<IChatHub, IMessageReceiver>(channel, this);
        // RegisterDisconnect(client);
        try
        {

            await client.JoinAsync(user, room);

            await client.SendMessageAsync("Who");
            await client.SendMessageAsync("Bar");
            await client.SendMessageAsync("Baz");

            await client.LeaveAsync();
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex);
        }
        finally
        {
            await client.DisposeAsync();
        }
    }

    async void RegisterDisconnect(IChatHub client)
    {
        try
        {
            // you can wait disconnected event
            await client.WaitForDisconnect();
        }
        finally
        {
            // try-to-reconnect? logging event? etc...
            Console.WriteLine("disconnected");
        }
    }

#pragma warning disable CS1998

    public async Task OnReceiveMessage(string senderUser, string message)
    {
        Console.WriteLine(senderUser + ":" + message);
    }
}

// ---- run test.

var foo = new ClientProgram().Start("Foo", "TEST_ROOM");
var bar = new ClientProgram().Start("Bar", "TEST_ROOM");

await Task.WhenAll(foo, bar);

[neuecc]

Unity supports(does not includes code generator so work only on unity editor).

Download latest gRPC/Unity build from gRPC build server and import it.
for example grpc_unity_package.1.18.0-dev.zip from this link.
https://packages.grpc.io/archive/2018/11/e0d9692fa30cf3a7a8410a722693d5d3d68fb0fd-1e59a50b-4ebf-4564-849e-ce82ca67fb17/index.xml

Import MagicOnion.Unity.2.0.1-alpha.zip package.

modifying player settings configuration like this.

• .NET 4.x Equivalent
• IL2CPP/Mono
• .NET 4.x
• ENABLE_UNSAFE_MSGPACK
• Allow unsafe Code

You can create MagicOnion client from StreamingHubClient.Connect or MagicOnionClient.Create.

[neuecc]

In NuGet, 2.0.2-alpha has been released.

All Hub methods wait server execution completed in default.
If you want to use FireAndForget, you can use client.FireAndForget().FooMethod().

All Hub methods receive exception when server throws exception.

Receiver interface's return type can choose both void and Task.

Add UniversalCodeGenerator(moc.exe), it supports linux-x64, win-x64, osx-x64.
moc supports StreamingHub code generate.

You can download moc and .unitypackage here.
https://github.com/neuecc/MagicOnion/releases/tag/2.0.2