Observable.ToObservable<TSource> Yöntemi (IEnumerable<TSource>, IScheduler)
Numaralandırılabilir bir diziyi, belirtilen kaynak ve zamanlayıcı ile gözlemlenebilir bir diziye dönüştürür.
Ad Alanı:System.Reactive.Linq
Derleme: System.Reactive (System.Reactive.dll içinde)
Syntax
'Declaration
<ExtensionAttribute> _
Public Shared Function ToObservable(Of TSource) ( _
source As IEnumerable(Of TSource), _
scheduler As IScheduler _
) As IObservable(Of TSource)
'Usage
Dim source As IEnumerable(Of TSource)
Dim scheduler As IScheduler
Dim returnValue As IObservable(Of TSource)
returnValue = source.ToObservable(scheduler)
public static IObservable<TSource> ToObservable<TSource>(
this IEnumerable<TSource> source,
IScheduler scheduler
)
[ExtensionAttribute]
public:
generic<typename TSource>
static IObservable<TSource>^ ToObservable(
IEnumerable<TSource>^ source,
IScheduler^ scheduler
)
static member ToObservable :
source:IEnumerable<'TSource> *
scheduler:IScheduler -> IObservable<'TSource>
JScript does not support generic types and methods.
Tür Parametreleri
- Tsource
Kaynak türü.
Parametreler
- kaynak
Tür: System.Collections.Generic.IEnumerable<TSource>
Gözlemlenebilir bir diziye dönüştürülecek numaralandırılabilir dizi.
- scheduler
Tür: System.Reactive.Concurrency.IScheduler
Giriş dizisinin numaralandırmasını çalıştıracak zamanlayıcı.
Dönüş Değeri
Tür: System.IObservable<TSource>
Öğeleri belirtilen numaralandırılabilir diziden çekilen gözlemlenebilir dizi.
Kullanım Notu
Visual Basic ve C# içinde, bu yöntemi IEnumerable<TSource> türündeki herhangi bir nesnede örnek yöntemi olarak çağırabilirsiniz. Bu yöntemi çağırmak için örnek yöntemi sözdizimini kullandığınızda, ilk parametreyi yok sayın. Daha fazla bilgi için bkz. veya .
Açıklamalar
ToObservable işleci, IEnumerable arabirimini destekleyen bir nesneden gözlemlenebilir bir dizi oluşturur. Gözlemlenebilir diziyi oluşturmak için gereken işleme için farklı zamanlama seçeneklerine izin vermek için bu işleçle birlikte bir zamanlayıcı parametresi sağlanır. Örneğin, başka bir iş parçacığında gerçekleşmesi gereken numaralandırma işlemini zamanlamak isteyebilirsiniz.
Örnekler
Bu örnek, System.IO döndürülen dize dizisi> tarafından kullanıma sunulan IEnumerable dizesinden> gözlemlenebilir bir dize dizisi (IObservable<<dize) oluşturur. Directory.GetDirectories yöntemi. Scheduler parametresi için ThreadPoolScheduler zamanlayıcı ToObservable işlecine geçirilir. Bu, numaralandırmanın .NET iş parçacığı havuzundan bir iş parçacığında çalıştırılmasına neden olur. Bu nedenle ana iş parçacığı engellenmez.
using System;
using System.IO;
using System.Reactive.Linq;
using System.Reactive.Concurrency;
namespace Example
{
class Program
{
static void Main()
{
//*********************************************************************************************************************//
//*** Create a new observable sequence from the IEnumerable<String> exposed by the string array returned from ***//
//*** System.IO.Directory.GetDirectories(). ***//
//*** ***//
//*** In this example we use the ThreadPool scheduler to run the enumeration on a thread in the .NET thread pool. ***//
//*** This way our main thread is not blocked by the enumeration and we can process user interaction. ***//
//*********************************************************************************************************************//
var fileList = Directory.GetDirectories(@"C:\Program Files");
var seqfiles = fileList.ToObservable(Scheduler.ThreadPool);
//*********************************************************************************************************************//
//*** We subscribe to this sequence with a lambda expression as the action event handler for the OnNext action. It ***//
//*** writes each filename to the console window. A action event handler for the OnCompleted action is also ***//
//*** provided to inform the user the sequence has ended and prompt for the ENTER key. ***//
//*********************************************************************************************************************//
Console.WriteLine("\nCreating subscription. Press ENTER to exit...\n");
seqfiles.Subscribe(f => Console.WriteLine(f.ToString()));
//*********************************************************************************************************************//
//*** Since we used the ThreadPool scheduler when creating the observable sequence, the enumeration is running on a ***//
//*** thread from the .NET thread pool. So the main thread is not blocked and can terminate the example if the user ***//
//*** presses ENTER for a long running enumeration. ***//
//*********************************************************************************************************************//
Console.ReadLine();
}
}
}
Aşağıdaki çıkış örnek kod kullanılarak oluşturulmuştur.
Creating subscription. Press ENTER to exit...
C:\Program Files\Common Files
C:\Program Files\IIS
C:\Program Files\Internet Explorer
C:\Program Files\Microsoft Games
C:\Program Files\Microsoft Help Viewer
C:\Program Files\Microsoft IntelliType Pro
C:\Program Files\Microsoft LifeCam
C:\Program Files\Microsoft Lync
C:\Program Files\Microsoft Office
C:\Program Files\Microsoft SDKs
C:\Program Files\Microsoft Security Client
C:\Program Files\Microsoft SQL Server
C:\Program Files\Microsoft SQL Server Compact Edition
C:\Program Files\Microsoft Sync Framework
C:\Program Files\Microsoft Synchronization Services
C:\Program Files\Microsoft Visual Studio 10.0
C:\Program Files\Microsoft Visual Studio 9.0
C:\Program Files\Microsoft.NET
C:\Program Files\MSBuild
C:\Program Files\Reference Assemblies
C:\Program Files\Uninstall Information
C:\Program Files\Windows Journal
C:\Program Files\Windows Live
C:\Program Files\Windows Mail
C:\Program Files\Windows Media Components
C:\Program Files\Windows Media Player
C:\Program Files\Windows NT
C:\Program Files\Windows Photo Viewer
C:\Program Files\Windows Portable Devices
C:\Program Files\Windows Sidebar
C:\Program Files\Zune