IConnection.cs

Go to the documentation of this file.

using Fauna.Mapping;
using Fauna.Types;
using Stream = System.IO.Stream;
 
namespace Fauna.Core;
 
internal interface IConnection : IDisposable
{
    Task<HttpResponseMessage> DoPostAsync(
        string path,
        Stream body,
        Dictionary<string, string> headers,
        TimeSpan requestTimeout,
        CancellationToken cancel);
 
 
    IAsyncEnumerable<Event<T>> OpenStream<T>(
        string path,
        Types.EventSource eventSource,
        Dictionary<string, string> headers,
        MappingContext ctx,
        CancellationToken cancellationToken = default) where T : notnull;
}