Untitled
unknown
plain_text
2 years ago
1.1 kB
4
Indexable
using System; using Grpc.Core; using System.Threading.Tasks; using ChatGrpc; namespace ChatClient { class Program { static async Task Main(string[] args) { var channel = new Channel("127.0.0.1:50051", ChannelCredentials.Insecure); var client = new Chat.ChatClient(channel); var user = "Alice"; var stream = client.Join(); var responseTask = Task.Run(async () => { while (await stream.ResponseStream.MoveNext()) { var message = stream.ResponseStream.Current; Console.WriteLine($"{message.User}: {message.Text}"); } }); await stream.RequestStream.WriteAsync(new Message { User = user, Text = "Hello, everyone!" }); Console.WriteLine("Type your messages:"); while (true) { var text = Console.ReadLine(); await stream.RequestStream.WriteAsync(new Message { User = user, Text = text }); } } } }
Editor is loading...