MelbourneDeveloper

using Microsoft.Extensions.Logging;
using Moq;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;

// More detailed samples here:
// https://github.com/MelbourneDeveloper/RestClient.Net/blob/79cca66e02f83a1043c44f215d374139f40f8c12/src/RestClient.Net.UnitTests/UnitTests.cs#L758

MelbourneDeveloper

internal class Observer<T> : IObserver<T>
{
    static Action<Exception> onError = ((e) => { });
    static Action onCompleted = (() => { });

    private readonly Action<T> _onNext;
    private readonly Action<Exception> _onError;
    private readonly Action _onCompleted;

    public Observer(

MelbourneDeveloper

#nullable enable

namespace NullObjectExample
{
    class Program
    {
        static void Main()
        {
            var someService = new SomeService();
        }

MelbourneDeveloper

#nullable enable

using System;

namespace Sample
{
    public class NullGuardExample
    {
        public string NotNullableProperty { get; }
        public string? NullableProperty { get; }

MelbourneDeveloper

#nullable enable

using Sample;
using System;

var testRecord = new TestRecord("Hi", null);
Console.WriteLine(testRecord.NotNullableProperty);

namespace Sample
{

MelbourneDeveloper

using Microsoft.AspNetCore.Mvc;

namespace WebApplication1.Controllers
{
    [ApiController]
    [Route("[controller]")]
    public class PersonController : ControllerBase
    {
        [HttpGet]
        public string Get(string firstName, string lastName) => $"{firstName} {lastName}";

MelbourneDeveloper

private static async Task DisplayTemperature()
{
    //Connect to the device by product id and vendor id
    var temperDevice = await new FilterDeviceDefinition(vendorId: 0x413d, productId: 0x2107, usagePage: 65280)
        .CreateWindowsHidDeviceFactory(_loggerFactory)
        .ConnectFirstAsync()
        .ConfigureAwait(false);

    //Create the observable
    var observable = Observable

MelbourneDeveloper

public static Task<T> PerformControlTransferWithRetry<T>(
    this IUsbDevice usbDevice,
    Func<IUsbDevice, Task<T>> func,
    int retryCount = 3,
    int sleepDurationMilliseconds = 250)
{
    var retryPolicy = Policy
        .Handle<ApiException>()
        .Or<ControlTransferException>()
        .WaitAndRetryAsync(

MelbourneDeveloper

var cancellationTokenSource = new CancellationTokenSource();
//Fire a timeout after 1000 milliseconds
cancellationTokenSource.CancelAfter(1000);
var result = await device.WriteAndReadAsync(writeData, cancellationTokenSource.Token);

MelbourneDeveloper

public static Task ClearStatusAsync(this IUsbDevice usbDevice)
    => usbDevice.PerformControlTransferAsync(new SetupPacket
    (
        requestType: new UsbDeviceRequestType(
            RequestDirection.In,
            RequestType.Class,
            RequestRecipient.Interface),
        request: DFU_CLEARSTATUS,
        length: 0
    ));