Qbservable.SelectMany<TSource, TResult> Method (IQbservable<TSource>, Expression<Func<TSource, IObservable<TResult>>>, Expression<Func<Exception, IObservable<TResult>>>, Expression<Func<IObservable<TResult>>>)
Проецирует каждый элемент запрашиваемой наблюдаемой последовательности в отслеживаемую последовательность, доступную для запроса, и преобразует итоговые отслеживаемые последовательности в одну отслеживаемую последовательность, доступную для запроса.
Пространство имен:System.Reactive.Linq
Сборки: System.Reactive.Providers (в System.Reactive.Providers.dll)
Синтаксис
'Declaration
<ExtensionAttribute> _
Public Shared Function SelectMany(Of TSource, TResult) ( _
source As IQbservable(Of TSource), _
onNext As Expression(Of Func(Of TSource, IObservable(Of TResult))), _
onError As Expression(Of Func(Of Exception, IObservable(Of TResult))), _
onCompleted As Expression(Of Func(Of IObservable(Of TResult))) _
) As IQbservable(Of TResult)
'Usage
Dim source As IQbservable(Of TSource)
Dim onNext As Expression(Of Func(Of TSource, IObservable(Of TResult)))
Dim onError As Expression(Of Func(Of Exception, IObservable(Of TResult)))
Dim onCompleted As Expression(Of Func(Of IObservable(Of TResult)))
Dim returnValue As IQbservable(Of TResult)
returnValue = source.SelectMany(onNext, _
onError, onCompleted)
public static IQbservable<TResult> SelectMany<TSource, TResult>(
this IQbservable<TSource> source,
Expression<Func<TSource, IObservable<TResult>>> onNext,
Expression<Func<Exception, IObservable<TResult>>> onError,
Expression<Func<IObservable<TResult>>> onCompleted
)
[ExtensionAttribute]
public:
generic<typename TSource, typename TResult>
static IQbservable<TResult>^ SelectMany(
IQbservable<TSource>^ source,
Expression<Func<TSource, IObservable<TResult>^>^>^ onNext,
Expression<Func<Exception^, IObservable<TResult>^>^>^ onError,
Expression<Func<IObservable<TResult>^>^>^ onCompleted
)
static member SelectMany :
source:IQbservable<'TSource> *
onNext:Expression<Func<'TSource, IObservable<'TResult>>> *
onError:Expression<Func<Exception, IObservable<'TResult>>> *
onCompleted:Expression<Func<IObservable<'TResult>>> -> IQbservable<'TResult>
JScript does not support generic types and methods.
Параметры типа
- TSource
Тип источника.
- TResult
Тип результата.
Параметры
- source
Тип: System.Reactive.Linq.IQbservable<TSource>
Запрашиваемая наблюдаемая последовательность элементов для проецируемого проекта.
- onNext
Тип: System.Linq.Expressions.Expression<Func<TSource, IObservable<TResult>>>
Функция преобразования, применяемая к каждому элементу.
- Onerror
Тип: Исключение Func System.Linq.Expressions.Expression<, IObservable<TResult<>>>
Функция преобразования, применяемая при возникновении ошибки в исходной последовательности.
- onCompleted
Тип: System.Linq.Expressions.Expression<Func<IObservable<TResult>>>
Функция преобразования, применяемая при достижении конца исходной последовательности.
Возвращаемое значение
Тип: System.Reactive.Linq.IQbservable<TResult>
Запрашиваемая наблюдаемая последовательность, элементы которой являются результатом вызова функции преобразования "один ко многим", соответствующей каждому уведомлению во входной последовательности.
Примечание об использовании
В Visual Basic и C# этот метод можно вызвать как метод экземпляра для любого объекта типа IQbservable<TSource>. При вызове метода для экземпляра следует опускать первый параметр. Дополнительные сведения см. в разделе или .