David Fowler davidfowl

Distinguished Engineer 🧐 at Microsoft on the .NET team, Creator of SignalR

davidfowl / workaround.cs

Created December 15, 2019 19:45

	using System;
	using Microsoft.AspNetCore.Builder;
	using Microsoft.AspNetCore.Hosting;
	using Microsoft.AspNetCore.Http;
	using Microsoft.AspNetCore.WebUtilities;
	using Microsoft.Extensions.Configuration;
	using Microsoft.Extensions.DependencyInjection;
	using Microsoft.Extensions.Hosting;

	namespace WebApplication404

davidfowl / parsingperf.cs

Last active November 12, 2019 00:45

Trying out various parsing techniques

	using System;
	using System.Buffers;
	using System.IO;
	using System.Text;
	using BenchmarkDotNet.Attributes;
	using BenchmarkDotNet.Diagnosers;
	using BenchmarkDotNet.Running;

	namespace MyBenchmarks
	{

davidfowl / CallbacksVsCode.md

Last active July 18, 2020 19:43

var state = new State();
var queue = new QueueClient();
try
{
    var item = await queue.DequeueAsync();
    state.Item = item;
}

davidfowl / AsyncEnumerableQueue.cs

Last active July 8, 2019 07:27

Event loop flipped inside out with IAsyncEnumerable

	using System;
	using System.Collections.Generic;
	using System.Text.Json;
	using System.Threading.Tasks;
	using Microsoft.Azure.ServiceBus;

	namespace ConsoleApp60
	{
	class Program
	{

davidfowl / Program.cs

Last active June 29, 2024 18:09

A minimal fully asynchronous C# ASP.NET Core 3.0 application with routing (learn more about ASP.NET Core here https://docs.microsoft.com/en-us/aspnet/core/?view=aspnetcore-3.0)

	using Microsoft.AspNetCore.Hosting;
	using Microsoft.AspNetCore.Builder;
	using Microsoft.AspNetCore.Http;
	using Microsoft.Extensions.Hosting;

	public class Program
	{
	public static void Main(string[] args) =>
	Host.CreateDefaultBuilder(args)
	.ConfigureWebHostDefaults(webBuilder =>

davidfowl / NamedPipeConnectionListener.cs

Created June 25, 2019 07:20

	public class NamedPipeConnectionListener : IConnectionListener
	{
	private readonly NamedPipeEndPoint _endpoint;
	private readonly CancellationTokenSource _listeningSource = new CancellationTokenSource();

	public NamedPipeConnectionListener(NamedPipeEndPoint endpoint)
	{
	_endpoint = endpoint;
	ListeningToken = _listeningSource.Token;
	}

davidfowl / DuplexPipe.cs

Last active June 7, 2019 18:54

	public class DuplexPipe<TStream> : Stream, IDuplexPipe where TStream : Stream
	{
	private readonly IDuplexPipe _duplexPipe;

	public DuplexPipe(IDuplexPipe duplexPipe, Func<Stream, TStream> wrapper)
	{
	_duplexPipe = duplexPipe;

	Stream = wrapper(this);
	Input = PipeReader.Create(Stream);

davidfowl / bedrock-server.cs

Last active December 8, 2022 15:18

A sample of the current API usage with bedrock's listener layer

	// Copyright (c) .NET Foundation. All rights reserved.
	// Licensed under the Apache License, Version 2.0. See License.txt in the project root for license information.

	using System;
	using System.Buffers;
	using System.Collections.Concurrent;
	using System.Collections.Generic;
	using System.Net;
	using System.Threading;
	using System.Threading.Tasks;

davidfowl / FormReaderExtensions.cs

Last active March 15, 2019 00:35

FormReader prototype

	public static class FormReaderExtensions
	{
	public static async ValueTask<IFormCollection> ReadFormAsync2(this HttpRequest request)
	{
	var reader = request.BodyPipe;
	KeyValueAccumulator accumulator = default;

	while (true)
	{
	var result = await reader.ReadAsync();

davidfowl / deps.json

Created February 24, 2019 01:47