Cara: Implementasi Penyedia

Artikel
04/07/2023

Pola desain pengamat memerlukan pembagian antara penyedia, yang memantau data dan mengirim pemberitahuan, serta satu atau beberapa pengamat, yang menerima pemberitahuan (panggilan balik) dari penyedia. Topik ini membahas cara membuat penyedia. Topik terkait, Cara: Menerapkan Pengamat, membahas cara membuat pengamat.

Untuk membuat penyedia

Tentukan data yang menjadi tanggung jawab penyedia untuk dikirim ke pengamat. Meskipun penyedia dan data yang dikirimnya ke pengamat bisa satu jenis saja, keduanya umumnya diwakili oleh berbagai jenis. Misalnya, dalam aplikasi pemantauan suhu, struktur Temperature menentukan data yang dipantau oleh penyedia (yang diwakili oleh kelas TemperatureMonitor, yang ditentukan di langkah berikutnya), dan yang menjadi langganan pengamat.

using System;

public struct Temperature
{
   private decimal temp;
   private DateTime tempDate;

   public Temperature(decimal temperature, DateTime dateAndTime)
   {
      this.temp = temperature;
      this.tempDate = dateAndTime;
   }

   public decimal Degrees
   { get { return this.temp; } }

   public DateTime Date
   { get { return this.tempDate; } }
}

Public Structure Temperature
    Private temp As Decimal
    Private tempDate As DateTime

    Public Sub New(ByVal temperature As Decimal, ByVal dateAndTime As DateTime)
        Me.temp = temperature
        Me.tempDate = dateAndTime
    End Sub

    Public ReadOnly Property Degrees As Decimal
        Get
            Return Me.temp
        End Get
    End Property

    Public ReadOnly Property [Date] As DateTime
        Get
            Return tempDate
        End Get
    End Property
End Structure

Tentukan penyedia data, yang merupakan jenis yang menerapkan antarmuka System.IObservable<T>. Argumen jenis generik penyedia adalah jenis yang dikirim penyedia ke pengamat. Contoh berikut mendefinisikan kelas TemperatureMonitor, yang merupakan konstruksi implementasi System.IObservable<T> dengan argumen Temperature jenis generik.
```
using System;
using System.Collections.Generic;

public class TemperatureMonitor : IObservable<Temperature>
{
```
```
Imports System.Collections.Generic


Public Class TemperatureMonitor : Implements IObservable(Of Temperature)
```

Tentukan bagaimana penyedia akan menyimpan referensi kepada pengamat sehingga setiap pengamat dapat diberi tahu jika sesuai. Umumnya, objek koleksi seperti objek List<T> generik digunakan untuk tujuan ini. Contoh berikut menentukan objek List<T> privat yang dibuat di konstruktor kelas TemperatureMonitor.

using System;
using System.Collections.Generic;

public class TemperatureMonitor : IObservable<Temperature>
{
   List<IObserver<Temperature>> observers;

   public TemperatureMonitor()
   {
      observers = new List<IObserver<Temperature>>();
   }

Imports System.Collections.Generic


Public Class TemperatureMonitor : Implements IObservable(Of Temperature)
    Dim observers As List(Of IObserver(Of Temperature))

    Public Sub New()
        observers = New List(Of IObserver(Of Temperature))
    End Sub

Tentukan implementasi IDisposable yang dapat kembalikan oleh penyedia ke pelanggan sehingga mereka dapat berhenti menerima pemberitahuan kapan saja. Contoh berikut mendefinisikan kelas Unsubscriber berlapis yang diteruskan referensi ke koleksi pelanggan dan kepada pelanggan saat kelas dibuat. Kode ini memungkinkan pelanggan untuk memanggil implementasi IDisposable.Dispose objek untuk menghapus dirinya sendiri dari koleksi pelanggan.

private class Unsubscriber : IDisposable
{
   private List<IObserver<Temperature>> _observers;
   private IObserver<Temperature> _observer;

   public Unsubscriber(List<IObserver<Temperature>> observers, IObserver<Temperature> observer)
   {
      this._observers = observers;
      this._observer = observer;
   }

   public void Dispose()
   {
      if (! (_observer == null)) _observers.Remove(_observer);
   }
}

Private Class Unsubscriber : Implements IDisposable
    Private _observers As List(Of IObserver(Of Temperature))
    Private _observer As IObserver(Of Temperature)

    Public Sub New(ByVal observers As List(Of IObserver(Of Temperature)), ByVal observer As IObserver(Of Temperature))
        Me._observers = observers
        Me._observer = observer
    End Sub

    Public Sub Dispose() Implements IDisposable.Dispose
        If _observer IsNot Nothing Then _observers.Remove(_observer)
    End Sub
End Class

Mengimplementasikan metode IObservable<T>.Subscribe. Metode ini diteruskan referensi ke antarmuka System.IObserver<T> dan harus disimpan dalam objek yang dirancang untuk tujuan tersebut di langkah 3. Metode ini kemudian harus mengembalikan implementasi IDisposable yang dikembangkan di langkah 4. Contoh berikut menunjukkan implementasi metode Subscribe di kelas TemperatureMonitor.

public IDisposable Subscribe(IObserver<Temperature> observer)
{
   if (! observers.Contains(observer))
      observers.Add(observer);

   return new Unsubscriber(observers, observer);
}

Public Function Subscribe(ByVal observer As System.IObserver(Of Temperature)) As System.IDisposable Implements System.IObservable(Of Temperature).Subscribe
    If Not observers.Contains(observer) Then
        observers.Add(observer)
    End If
    Return New Unsubscriber(observers, observer)
End Function

Beri tahu pengamat yang sesuai dengan memanggil implementasi IObserver<T>.OnNext, IObserver<T>.OnError, dan IObserver<T>.OnCompleted mereka. Dalam beberapa kasus, penyedia mungkin tidak memanggil metode OnError ketika kesalahan terjadi. Misalnya, metode GetTemperature berikut menyimulasikan monitor yang membaca data suhu setiap lima detik dan memberi tahu pengamat jika suhu telah berubah setidaknya .1 derajat sejak pembacaan sebelumnya. Jika perangkat tidak melaporkan suhu (yaitu, jika nilainya null), penyedia memberi tahu pengamat bahwa transmisi selesai. Perhatikan bahwa, selain memanggil metode OnCompleted setiap pengamat, metode GetTemperature menghapus koleksi List<T>. Dalam hal ini, penyedia tidak melakukan panggilan ke metode OnError dari pengamatnya.

public void GetTemperature()
{
   // Create an array of sample data to mimic a temperature device.
   Nullable<Decimal>[] temps = {14.6m, 14.65m, 14.7m, 14.9m, 14.9m, 15.2m, 15.25m, 15.2m,
                                15.4m, 15.45m, null };
   // Store the previous temperature, so notification is only sent after at least .1 change.
   Nullable<Decimal> previous = null;
   bool start = true;

   foreach (var temp in temps) {
      System.Threading.Thread.Sleep(2500);
      if (temp.HasValue) {
         if (start || (Math.Abs(temp.Value - previous.Value) >= 0.1m )) {
            Temperature tempData = new Temperature(temp.Value, DateTime.Now);
            foreach (var observer in observers)
               observer.OnNext(tempData);
            previous = temp;
            if (start) start = false;
         }
      }
      else {
         foreach (var observer in observers.ToArray())
            if (observer != null) observer.OnCompleted();

         observers.Clear();
         break;
      }
   }
}

Public Sub GetTemperature()
    ' Create an array of sample data to mimic a temperature device.
    Dim temps() As Nullable(Of Decimal) = {14.6D, 14.65D, 14.7D, 14.9D, 14.9D, 15.2D, 15.25D, 15.2D,
                                          15.4D, 15.45D, Nothing}
    ' Store the previous temperature, so notification is only sent after at least .1 change.
    Dim previous As Nullable(Of Decimal)
    Dim start As Boolean = True

    For Each temp In temps
        System.Threading.Thread.Sleep(2500)

        If temp.HasValue Then
            If start OrElse Math.Abs(temp.Value - previous.Value) >= 0.1 Then
                Dim tempData As New Temperature(temp.Value, Date.Now)
                For Each observer In observers
                    observer.OnNext(tempData)
                Next
                previous = temp
                If start Then start = False
            End If
        Else
            For Each observer In observers.ToArray()
                If observer IsNot Nothing Then observer.OnCompleted()
            Next
            observers.Clear()
            Exit For
        End If
    Next
End Sub

Contoh

Contoh berikut berisi kode sumber lengkap untuk menentukan implementasi IObservable<T> bagi aplikasi pemantauan suhu. Hal ini mencakup struktur Temperature, yang merupakan data yang dikirim ke pengamat, dan kelas TemperatureMonitor, yang merupakan implementasi IObservable<T>.

using System.Threading;
using System;
using System.Collections.Generic;

public class TemperatureMonitor : IObservable<Temperature>
{
   List<IObserver<Temperature>> observers;

   public TemperatureMonitor()
   {
      observers = new List<IObserver<Temperature>>();
   }

   private class Unsubscriber : IDisposable
   {
      private List<IObserver<Temperature>> _observers;
      private IObserver<Temperature> _observer;

      public Unsubscriber(List<IObserver<Temperature>> observers, IObserver<Temperature> observer)
      {
         this._observers = observers;
         this._observer = observer;
      }

      public void Dispose()
      {
         if (! (_observer == null)) _observers.Remove(_observer);
      }
   }

   public IDisposable Subscribe(IObserver<Temperature> observer)
   {
      if (! observers.Contains(observer))
         observers.Add(observer);

      return new Unsubscriber(observers, observer);
   }

   public void GetTemperature()
   {
      // Create an array of sample data to mimic a temperature device.
      Nullable<Decimal>[] temps = {14.6m, 14.65m, 14.7m, 14.9m, 14.9m, 15.2m, 15.25m, 15.2m,
                                   15.4m, 15.45m, null };
      // Store the previous temperature, so notification is only sent after at least .1 change.
      Nullable<Decimal> previous = null;
      bool start = true;

      foreach (var temp in temps) {
         System.Threading.Thread.Sleep(2500);
         if (temp.HasValue) {
            if (start || (Math.Abs(temp.Value - previous.Value) >= 0.1m )) {
               Temperature tempData = new Temperature(temp.Value, DateTime.Now);
               foreach (var observer in observers)
                  observer.OnNext(tempData);
               previous = temp;
               if (start) start = false;
            }
         }
         else {
            foreach (var observer in observers.ToArray())
               if (observer != null) observer.OnCompleted();

            observers.Clear();
            break;
         }
      }
   }
}

Imports System.Threading
Imports System.Collections.Generic


Public Class TemperatureMonitor : Implements IObservable(Of Temperature)
    Dim observers As List(Of IObserver(Of Temperature))

    Public Sub New()
        observers = New List(Of IObserver(Of Temperature))
    End Sub

    Private Class Unsubscriber : Implements IDisposable
        Private _observers As List(Of IObserver(Of Temperature))
        Private _observer As IObserver(Of Temperature)

        Public Sub New(ByVal observers As List(Of IObserver(Of Temperature)), ByVal observer As IObserver(Of Temperature))
            Me._observers = observers
            Me._observer = observer
        End Sub

        Public Sub Dispose() Implements IDisposable.Dispose
            If _observer IsNot Nothing Then _observers.Remove(_observer)
        End Sub
    End Class

    Public Function Subscribe(ByVal observer As System.IObserver(Of Temperature)) As System.IDisposable Implements System.IObservable(Of Temperature).Subscribe
        If Not observers.Contains(observer) Then
            observers.Add(observer)
        End If
        Return New Unsubscriber(observers, observer)
    End Function

    Public Sub GetTemperature()
        ' Create an array of sample data to mimic a temperature device.
        Dim temps() As Nullable(Of Decimal) = {14.6D, 14.65D, 14.7D, 14.9D, 14.9D, 15.2D, 15.25D, 15.2D,
                                              15.4D, 15.45D, Nothing}
        ' Store the previous temperature, so notification is only sent after at least .1 change.
        Dim previous As Nullable(Of Decimal)
        Dim start As Boolean = True

        For Each temp In temps
            System.Threading.Thread.Sleep(2500)

            If temp.HasValue Then
                If start OrElse Math.Abs(temp.Value - previous.Value) >= 0.1 Then
                    Dim tempData As New Temperature(temp.Value, Date.Now)
                    For Each observer In observers
                        observer.OnNext(tempData)
                    Next
                    previous = temp
                    If start Then start = False
                End If
            Else
                For Each observer In observers.ToArray()
                    If observer IsNot Nothing Then observer.OnCompleted()
                Next
                observers.Clear()
                Exit For
            End If
        Next
    End Sub
End Class

Bagikan melalui

Cara: Implementasi Penyedia

Untuk membuat penyedia

Contoh

Lihat juga

Sumber Daya Tambahan: