Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
AGeorgy authored May 30, 2022
1 parent 08e8f8b commit a65b7c1
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions src/MessagePipe/GlobalMessagePipe.cs
Original file line number Diff line number Diff line change
Expand Up @@ -109,25 +109,25 @@ public static IAsyncRequestAllHandler<TRequest, TResponse> GetAsyncRequestAllHan
return provider.GetRequiredService<IAsyncRequestAllHandler<TRequest, TResponse>>();
}

public static IBufferedPublisher<TMessage> GetPublisher<TMessage>()
public static IBufferedPublisher<TMessage> GetBufferedPublisher<TMessage>()
{
ThrowIfNotInitialized();
return provider.GetRequiredService<IBufferedPublisher<TMessage>>();
}

public static IBufferedSubscriber<TMessage> GetSubscriber<TMessage>()
public static IBufferedSubscriber<TMessage> GetBufferedSubscriber<TMessage>()
{
ThrowIfNotInitialized();
return provider.GetRequiredService<IBufferedSubscriber<TMessage>>();
}

public static IBufferedAsyncPublisher<TMessage> GetPublisher<TMessage>()
public static IBufferedAsyncPublisher<TMessage> GetAsyncBufferedPublisher<TMessage>()
{
ThrowIfNotInitialized();
return provider.GetRequiredService<IBufferedAsyncPublisher<TMessage>>();
}

public static IBufferedAsyncSubscriber<TMessage> GetSubscriber<TMessage>()
public static IBufferedAsyncSubscriber<TMessage> GetAsyncBufferedSubscriber<TMessage>()
{
ThrowIfNotInitialized();
return provider.GetRequiredService<IBufferedAsyncSubscriber<TMessage>>();
Expand Down

0 comments on commit a65b7c1

Please sign in to comment.