using Newtonsoft.Json;
using Supabase.Realtime.Models;
var url = "http://127.0.0.1:64321";
var key = "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJzdXBhYmFzZS1kZW1vIiwicm9sZSI6InNlcnZpY2Vfcm9sZSIsImV4cCI6MTk4MzgxMjk5Nn0.EGIM96RAZx35lJzdJsyH-qQwv8Hdp7fsn3W0YpN81IU";
var options = new Supabase.SupabaseOptions
{
AutoConnectRealtime = true
};
var supabase = new Supabase.Client(url, key, options);
await supabase.InitializeAsync();
var channel = supabase.Realtime.Channel("test-channel");
var broadcast = channel.Register<Broadcast>();
// Listen for all broadcast events, filter for 'shout' inside the handler
broadcast.AddBroadcastEventHandler((sender, baseBroadcast) =>
{
var response = broadcast.Current();
});
await channel.Subscribe();
class Broadcast : BaseBroadcast
{
[JsonProperty("message")]
public string? Message { get; set; }
}
using Newtonsoft.Json;
using Supabase.Realtime.Models;
var url = "http://127.0.0.1:64321";
var key = "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJzdXBhYmFzZS1kZW1vIiwicm9sZSI6InNlcnZpY2Vfcm9sZSIsImV4cCI6MTk4MzgxMjk5Nn0.EGIM96RAZx35lJzdJsyH-qQwv8Hdp7fsn3W0YpN81IU";
var options = new Supabase.SupabaseOptions
{
AutoConnectRealtime = true
};
var supabase = new Supabase.Client(url, key, options);
await supabase.InitializeAsync();
var channel = supabase.Realtime.Channel("test-channel");
var broadcast = channel.Register<Broadcast>();
// Listen for all broadcast events, filter for 'shout' inside the handler
broadcast.AddBroadcastEventHandler((sender, baseBroadcast) =>
{
var response = broadcast.Current();
});
await channel.Subscribe();
class Broadcast : BaseBroadcast
{
[JsonProperty("message")]
public string? Message { get; set; }
}