Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
public abstract class PersistentConnection
{
public virtual void Initialize(IDependencyResolver resolver);
public bool Authorize(IRequest request);
protected virtual TraceSource Trace { get; } }
protected IProtectedData ProtectedData { get; private set; }
protected IMessageBus MessageBus { get; private set; }
protected JsonSerializer JsonSerializer { get; private set; }
protected IAckHandler AckHandler { get; private set; }
protected ITraceManager TraceManager { get; private set; }
protected IPerformanceCounterManager Counters { get; private set; }
protected ITransport Transport { get; private set; }
protected IUserIdProvider UserIdProvider { get; private set; }
public IConnection Connection { get; private set; }
public IConnectionGroupManager Groups { get; private set; }
public Task ProcessRequest(IDictionary<string, object> environment);
public virtual Task ProcessRequest(HostContext context);
protected virtual IList<string> GetSignals(string userId, string connectionId);
protected virtual bool AuthorizeRequest(IRequest request);
protected virtual IList<string> OnRejoiningGroups(IRequest request, IList<string> groups, string connectionId);
protected virtual Task OnConnected(IRequest request, string connectionId);
protected virtual Task OnReconnected(IRequest request, string connectionId);
protected virtual Task OnReceived(IRequest request, string connectionId, string data);
protected virtual Task OnDisconnected(IRequest request, string connectionId, bool stopCalled);
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.