markotny

import {Observable} from 'rxjs';

/**
 * Stream server data (e.g. from endpoint returning IAsyncEnumerable)
 * @type T type of stream element
 * @param input input param of {@link fetch}
 * @param init init param of {@link fetch} (excluding abort signal)
 * @return stream of array elements one by one
 */
export function fromFetchStream<T>(input: RequestInfo, init?: RequestInit): Observable<T> {

markotny

using Microsoft.Extensions.Logging;

namespace XunitLogging;

/// <summary>
/// Buffers all logs in a queue until an actual ILogger is registered
/// </summary>
internal class TestOutputBuffer : ILogger
{
	private readonly Queue<Action<ILogger>> _bufferedLogs = new();

markotny

using System.Linq.Expressions;

namespace LeftJoin;

public static class ExpressionExtensions
{
	/// <inheritdoc cref="Compose{TFunc}"/>
	public static Expression<Func<P1, TRes>> Compose<P1, TP1, TRes>(
		this Expression<Func<TP1, TRes>> function,
		Expression<Func<P1, TP1>> firstParamSelector)