• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Python streampy.Stream类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Python中streampy.Stream的典型用法代码示例。如果您正苦于以下问题:Python Stream类的具体用法?Python Stream怎么用?Python Stream使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



在下文中一共展示了Stream类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。

示例1: test_simple_3

 def test_simple_3(self):
     element = Stream.range(100000) \
         .filter(lambda x: x % 2 == 0) \
         .map(lambda x: str(x)) \
         .map(lambda x: 'Hi{0}'.format(x)) \
         .map(lambda x: x.upper()) \
         .filter(lambda x: x.endswith('8')) \
         .limit(10) \
         .map(lambda x: x[2]) \
         .skip(1) \
         .map(int) \
         .list()
     self.assertEquals(element, list(range(1, 10)))
开发者ID:tolsac,项目名称:streampy,代码行数:13,代码来源:tests.py


示例2: test_create_stream_with_list_params

 def test_create_stream_with_list_params(self):
     s = Stream([])
     self.assertEquals(0, s.size())
     s = Stream([1])
     self.assertEquals(1, s.size())
开发者ID:tolsac,项目名称:streampy,代码行数:5,代码来源:tests.py


示例3: test_simple_map_1

    def test_simple_map_1(self):
        def add(x, y):
            return x + y

        s = Stream.range(10000).map(lambda x: x * 2).reduce(add, initializer=0)
        self.assertEquals(s, 99990000)
开发者ID:tolsac,项目名称:streampy,代码行数:6,代码来源:tests.py


示例4: test_simple_exclude_3

 def test_simple_exclude_3(self):
     s = Stream.range(100001).exclude(lambda x: x > 50000)
     self.assertEquals(50001, s.size())
开发者ID:tolsac,项目名称:streampy,代码行数:3,代码来源:tests.py


示例5: test_simple_filter_3

 def test_simple_filter_3(self):
     s = Stream.range(100001).filter(lambda x: x > 50000)
     self.assertEquals(50000, s.size())
开发者ID:tolsac,项目名称:streampy,代码行数:3,代码来源:tests.py


示例6: test_simple_size_3

 def test_simple_size_3(self):
     s = Stream("azertyuiop").filter(lambda x: x == 'a')
     self.assertEquals(s.size(), 1)
开发者ID:tolsac,项目名称:streampy,代码行数:3,代码来源:tests.py


示例7: test_simple_size_1

 def test_simple_size_1(self):
     self.assertEquals(Stream.range(999).size(), 999)
开发者ID:tolsac,项目名称:streampy,代码行数:2,代码来源:tests.py


示例8: test_simple_last_3

 def test_simple_last_3(self):
     self.assertEquals(Stream.range(423).last(predicate=lambda x: 42 < x < 46), 45)
开发者ID:tolsac,项目名称:streampy,代码行数:2,代码来源:tests.py


示例9: test_simple_last_1

 def test_simple_last_1(self):
     self.assertEquals(Stream.range(10).last(), 9)
开发者ID:tolsac,项目名称:streampy,代码行数:2,代码来源:tests.py


示例10: test_simple_last_2

 def test_simple_last_2(self):
     self.assertEquals(Stream.range(10).last(predicate=lambda x: x > 1), 9)
开发者ID:tolsac,项目名称:streampy,代码行数:2,代码来源:tests.py


示例11: test_create_stream_with_generator_params

 def test_create_stream_with_generator_params(self):
     s = Stream.range(1000)
     self.assertEquals(1000, s.size())
开发者ID:tolsac,项目名称:streampy,代码行数:3,代码来源:tests.py


示例12: test_simple_first_1

 def test_simple_first_1(self):
     self.assertEquals(Stream.range(10).first(), 0)
开发者ID:tolsac,项目名称:streampy,代码行数:2,代码来源:tests.py


示例13: test_simple_range_2

 def test_simple_range_2(self):
     self.assertEquals(Stream.range(42000).list(), list(range(42000)))
开发者ID:tolsac,项目名称:streampy,代码行数:2,代码来源:tests.py


示例14: test_simple_chunk_2

 def test_simple_chunk_2(self):
     self.assertEqual(Stream.range(10).chunk(3).list(), [[0, 1, 2], [3, 4, 5], [6, 7, 8], [9]])
开发者ID:tolsac,项目名称:streampy,代码行数:2,代码来源:tests.py


示例15: test_simple_skip_1

 def test_simple_skip_1(self):
     self.assertEquals(Stream.range(10).skip(9).list(), [9])
开发者ID:tolsac,项目名称:streampy,代码行数:2,代码来源:tests.py


示例16: test_simple_chunk_3

 def test_simple_chunk_3(self):
     self.assertEqual(Stream.range(1).chunk(2).list(), [[0]])
开发者ID:tolsac,项目名称:streampy,代码行数:2,代码来源:tests.py


示例17: test_simple_skip_2

 def test_simple_skip_2(self):
     self.assertEquals(Stream.range(10).skip(15).list(), [])
开发者ID:tolsac,项目名称:streampy,代码行数:2,代码来源:tests.py


示例18: test_collect_simple_list

 def test_collect_simple_list(self):
     lst = Stream.range(10) \
         .map(lambda x: x * 2) \
         .collect(Collector.list())
     self.assertEqual(lst, [0, 2, 4, 6, 8, 10, 12, 14, 16, 18])
开发者ID:tolsac,项目名称:streampy,代码行数:5,代码来源:tests.py


示例19: test_simple_getitem_1

 def test_simple_getitem_1(self):
     self.assertEquals(Stream.range(10)[0], 0)
开发者ID:tolsac,项目名称:streampy,代码行数:2,代码来源:tests.py


示例20: test_simple_size_2

 def test_simple_size_2(self):
     self.assertEquals(Stream.range(0).size(), 0)
开发者ID:tolsac,项目名称:streampy,代码行数:2,代码来源:tests.py



注:本文中的streampy.Stream类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Python streams.serial函数代码示例发布时间:2022-05-27
下一篇:
Python stream.HLSStream类代码示例发布时间:2022-05-27
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap