<PackageReference Include="System.Reactive" Version="6.0.0-preview.13" />
    
	
	
		
		
		
	 
	
	
        
                
                LastBlocking<T>
                
                
                
                
using System.
Runtime.
CompilerServices;
namespace System.
Reactive.
Linq.
ObservableImpl
{
    [
System.
Runtime.
CompilerServices.
NullableContext(
1)]
    [
System.
Runtime.
CompilerServices.
Nullable(
new byte[] {
        
0,
        
1
    })]
    
internal sealed class LastBlocking<[
System.
Runtime.
CompilerServices.
Nullable(
2)] 
T> : 
BaseBlocking<
T>
    {
        
public override void OnNext(
T value)
        {
            
_value = 
value;
            
_hasValue = 
true;
        }
    }
}