上一节:
下一节:

  RxPY - 过滤运算符

  • debounce

    该运算符将给出源 observable 的值，直到给定的时间跨度，如果时间过去，则忽略其余的值。

    句法

    

debounce(duetime)

    参数

    Duetime：这将以秒或时间实例为单位，持续时间将决定从源 observable 返回的值。

    例子

    

from rx import of, operators as op

from datetime import date

test = of(1,2,3,4,5,6,7,8,9,10)

sub1 = test.pipe(

   op.debounce(2.0)

)

sub1.subscribe(lambda x: print("The value is {0}".format(x)))

    输出

    

E:\pyrx>python testrx.py

The value is 10

  • distinct

    该运算符将给出与源 observable 不同的所有值。

    句法

    

distinct()

    返回值

    它将返回一个 observable，其中它将具有与源 observable 不同的值。

    例子

    

from rx import of, operators as op

from datetime import date

test = of(1, 6, 15, 1, 10, 6, 40, 10, 58, 20, 40)

sub1 = test.pipe(

   op.distinct()

)

sub1.subscribe(lambda x: print("The distinct value is {0}".format(x)))

    输出

    

E:\pyrx>python testrx.py

The distinct value is 1

The distinct value is 6

The distinct value is 15

The distinct value is 10

The distinct value is 40

The distinct value is 58

The distinct value is 20

  • element_at

    该运算符将为给定的索引从源 observable 中给出一个元素。

    句法

    

element_at(index)

    参数

    index：从零开始的数字，您需要源 observable 中的元素。

    返回值

    它将返回一个带有给定索引的源 observable 值的 observable。

    例子

    

from rx import of, operators as op

from datetime import date

test = of(1, 6, 15, 1, 10, 6, 40, 10, 58, 20, 40)

sub1 = test.pipe(

   op.element_at(5)

)

sub1.subscribe(lambda x: print("The value is {0}".format(x)))

    输出

    

E:\pyrx>python testrx.py

The value is 6

  • filter

    该运算符将根据给定的谓词函数过滤来自可观察源的值。

    句法

    

filter(predicate_func)

    参数

    predicate_func：这个函数将决定从源 observable 中过滤的值。

    返回值

    它将返回一个 observable，该 observable 将具有来自基于谓词函数的源 observable 的过滤值。

    例子

    

from rx import of, operators as op

from datetime import date

test = of(1, 6, 15, 1, 10, 6, 40, 10, 58, 20, 40)

sub1 = test.pipe(

   op.filter(lambda x : x %2==0)

)

sub1.subscribe(lambda x: print("The filtered value is {0}".format(x)))
    在示例中，我们过滤了所有偶数。

    输出

    

E:\pyrx>python testrx.py

The filtered value is 6

The filtered value is 10

The filtered value is 6

The filtered value is 40

The filtered value is 10

The filtered value is 58

The filtered value is 20

The filtered value is 40

  • first

    该运算符将给出源 observable 中的第一个元素。

    句法

    

first(predicate_func=None)

    参数

    predicate_func：（可选）如果通过，此函数将根据条件决定要选择的第一个元素。

    返回值

    它将返回一个带有源 observable 的第一个值的 observable。

    例子

    

from rx import of, operators as op

from datetime import date

test = of(1, 6, 15, 1, 10, 6, 40, 10, 58, 20, 40)

sub1 = test.pipe(

   op.first()

)

sub1.subscribe(lambda x: print("The first element is {0}".format(x)))

    输出

    

E:\pyrx>python testrx.py

The first element is 1

    示例 2：使用 predicate_func

    

from rx import of, operators as op

from datetime import date

test = of(1, 6, 15, 1, 10, 6, 40, 10, 58, 20, 40)

sub1 = test.pipe(

   op.first(lambda x : x%2==0)

)

sub1.subscribe(lambda x: print("The first element is {0}".format(x)))

    输出

    

E:\pyrx>python test1.py

The first element is 6

  • ignore_elements

    该运算符将忽略源 Observable 中的所有值，并且只执行对完成或错误回调函数的调用。

    句法

    

ignore_elements()

    返回值

    它返回一个 observable，它将根据源 observable 调用完成或错误。

    例子

    

from rx import of, operators as op

from datetime import date

test = of(1, 6, 15, 1, 10, 6, 40, 10, 58, 20, 40)

sub1 = test.pipe(

   op.ignore_elements()

)

sub1.subscribe(lambda x: print("The first element is {0}".format(x)),

lambda e: print("Error : {0}".format(e)),

lambda: print("Job Done!"))

    输出

    

E:\pyrx>python testrx.py

Job Done!

  • last

    该运算符将给出源 observable 中的最后一个元素。

    句法

    

last(predicate_func=None)

    参数

    predicate_func：（可选）如果通过，此函数将根据条件决定要选择的最后一个元素。

    返回值

    它将返回一个带有源 observable 的最后一个值的 observable。

    例子

    

from rx import of, operators as op

from datetime import date

test = of(1, 6, 15, 1, 10, 6, 40, 10, 58, 20, 40)

sub1 = test.pipe(

   op.last()

)

sub1.subscribe(lambda x: print("The last element is {0}".format(x)))

    输出

    

E:\pyrx>python test1.py

The last element is 40

  • skip

    该运算符将返回一个 observable，它将跳过作为输入的计数项的第一次出现。

    句法

    

skip(count)

    参数

    count：计数是从源 observable 中跳过项目的次数。

    返回值

    它将返回一个 observable，根据给定的计数跳过值。

    例子

    

from rx import of, operators as op

from datetime import date

test = of(1, 2,3,4,5,6,7,8,9,10)

sub1 = test.pipe(

   op.skip(5)

)

sub1.subscribe(lambda x: print("The element is {0}".format(x)))

    输出

    

E:\pyrx>python testrx.py

The element is 6

The element is 7

The element is 8

The element is 9

The element is 10

  • skip_last

    该运算符将返回一个 observable，它将跳过最后一次出现的计数项作为输入。

    句法

    

skip_last(count)

    参数

    count：计数是从源 observable 中跳过项目的次数。

    返回值

    它将返回一个 observable，它会根据 last 给出的计数跳过值。

    例子

    

from rx import of, operators as op

from datetime import date

test = of(1, 2,3,4,5,6,7,8,9,10)

sub1 = test.pipe(

   op.skip_last(5)

)

sub1.subscribe(lambda x: print("The element is {0}".format(x)))

    输出

    

E:\pyrx>python testrx.py

The element is 1

The element is 2

The element is 3

The element is 4

The element is 5

  • take

    该运算符将根据给定的计数以连续顺序给出源值列表。

    句法

    

take(count)

    参数

    count：计数是项目的数量，将从可观察的源中给出。

    返回值

    它将根据给定的计数返回一个具有连续顺序的值的 observable。

    例子

    

from rx import of, operators as op

from datetime import date

test = of(1, 2,3,4,5,6,7,8,9,10)

sub1 = test.pipe(

   op.take(5)

)

sub1.subscribe(lambda x: print("The element is {0}".format(x)))

    输出

    

E:\pyrx>python testrx.py

The element is 1

The element is 2

The element is 3

The element is 4

The element is 5

  • take_last

    该运算符将根据给定的计数以从最后一个连续的顺序给出源值列表。

    句法

    

take_last(count)

    参数

    count：计数是项目的数量，将从可观察的源中给出。

    返回值

    它将返回一个 observable，它的值根据给定的计数从最后一个连续顺序排列。

    例子

    from rx import of, operators as op

from datetime import date

test = of(1, 2,3,4,5,6,7,8,9,10)

sub1 = test.pipe(

   op.take_last(5)

)

sub1.subscribe(lambda x: print("The element is {0}".format(x)))

    输出

    

E:\pyrx>python testrx.py

The element is 6

The element is 7

The element is 8

The element is 9

The element is 10
上一节:
下一节: