Streamer

KO | EN

gitlite — search

#python #hacktoberfest #typescript #go #android #machine-learning #docker #nodejs #macos #java #windows #pytorch #ios #open-source

(★ 44)

JSON RPC over any bidirectional stream

Streamer Latest Version Download

// repository documentation

★ 0 (0 ratings)

# Streamer

RPC over a network should be simpler so here you go. Streamer offers a simple API for RPC over any bidirectional stream.

## NuGet

```
Install-Package Streamer
```

## Server

```C#
var server = new TcpListener(IPAddress.Loopback, 1335);
server.Start();

while (true)
{
    var client = await server.AcceptTcpClientAsync();

// Create a channel to communicate with the client
    var channel = Channel.CreateServer(client.GetStream());

// Bind the handler that will handle callbacks
    channel.Bind(new Handler());
}

public class Handler
{
    public int Increment(int value)
    {
        Console.WriteLine("Received " + value);

return value + 1;
    }
}

```

## Client

```C#
var client = new TcpClient();
await client.ConnectAsync(IPAddress.Loopback, 1335);

// Create a channel so we can communicate with the server
var channel = Channel.CreateClient(client.GetStream());

// Invoke a method and get a result
var result = await channel.Invoke<int>("Increment");
```

## Typed Clients

```C#
public interface IAdder
{
    Task<int> Increment(int value);
}

var client = new TcpClient();
await client.ConnectAsync(IPAddress.Loopback, 1335);

// Create a channel so we can communicate with the server
var channel = new Channel(client.GetStream());

// Create a proxy to the adder interface
var adder = channel.As<IAdder>();

// Invoke a method and get a result
var result = await adder.Increment(0);
```