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

PHP onError函数代码示例

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

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



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

示例1: getMysqli

function getMysqli()
{
    $_db = new mysqli(HOST, DB_USER, DB_PASS, DB);
    if ($_db->connect_errno > 0) {
        onError("Unable to connect to database.", $_db->connect_error);
    }
    return $_db;
}
开发者ID:gogolB,项目名称:pinkies2,代码行数:8,代码来源:functions.php


示例2: sum_number_throw

 /**
  * Adapted from RxJS
  *
  * @test
  */
 public function sum_number_throw()
 {
     $xs = $this->createHotObservable([onNext(150, 1), onError(210, new \Exception())]);
     $results = $this->scheduler->startWithCreate(function () use($xs) {
         return $xs->sum();
     });
     $this->assertMessages([onError(210, new \Exception())], $results->getMessages());
 }
开发者ID:ReactiveX,项目名称:RxPHP,代码行数:13,代码来源:SumTest.php


示例3: select_calls_on_error

 /**
  * @test
  */
 public function select_calls_on_error()
 {
     $xs = $this->createHotObservable(array(onError(500, new Exception())));
     $results = $this->scheduler->startWithCreate(function () use($xs) {
         return $xs->select('RxIdentity');
     });
     $this->assertMessages(array(onError(500, new Exception())), $results->getMessages());
 }
开发者ID:Gasperowicz,项目名称:Rx.PHP,代码行数:11,代码来源:SelectTest.php


示例4: timestamp_error

 /**
  * @test
  */
 public function timestamp_error()
 {
     $error = new \Exception();
     $results = $this->scheduler->startWithCreate(function () use($error) {
         return Observable::error($error)->timestamp($this->scheduler);
     });
     $this->assertMessages([onError(201, $error)], $results->getMessages());
 }
开发者ID:ReactiveX,项目名称:RxPHP,代码行数:11,代码来源:TimestampTest.php


示例5: startWith_error

 /**
  * @test
  */
 public function startWith_error()
 {
     $error = new \Exception();
     $xs = $this->createHotObservable([onNext(150, 1), onError(250, $error)]);
     $results = $this->scheduler->startWithCreate(function () use($xs) {
         return $xs->startWithArray([1, 2, 3]);
     });
     $this->assertMessages([onNext(201, 1), onNext(202, 2), onNext(203, 3), onError(250, $error)], $results->getMessages());
 }
开发者ID:ReactiveX,项目名称:RxPHP,代码行数:12,代码来源:StartWithTest.php


示例6: testAsObservableThrow

 public function testAsObservableThrow()
 {
     $error = new Exception();
     $xs = $this->createHotObservable([onNext(150, 1), onError(250, $error)]);
     $results = $this->scheduler->startWithCreate(function () use($xs) {
         return $xs->asObservable();
     });
     $this->assertMessages([onError(250, $error)], $results->getMessages());
 }
开发者ID:voryx,项目名称:Rx.PHP,代码行数:9,代码来源:AsObservableTest.php


示例7: switchLatest_outer_throws

 /**
  * @test
  */
 public function switchLatest_outer_throws()
 {
     $error = new \Exception();
     $xs = $this->createHotObservable([onNext(300, $this->createColdObservable([onNext(10, 101), onNext(20, 102), onNext(110, 103), onNext(120, 104), onNext(210, 105), onNext(220, 106), onCompleted(230)])), onNext(400, $this->createColdObservable([onNext(10, 201), onNext(20, 202), onNext(30, 203), onNext(40, 204), onCompleted(50)])), onError(500, $error)]);
     $results = $this->scheduler->startWithCreate(function () use($xs) {
         return $xs->switchLatest();
     });
     $this->assertMessages([onNext(310, 101), onNext(320, 102), onNext(410, 201), onNext(420, 202), onNext(430, 203), onNext(440, 204), onError(500, $error)], $results->getMessages());
 }
开发者ID:ReactiveX,项目名称:RxPHP,代码行数:12,代码来源:SwitchLatestTest.php


示例8: pluck_object_property_missing

 /**
  * @test
  */
 public function pluck_object_property_missing()
 {
     $xs = $this->createHotObservable([onNext(180, (object) ['prop' => 1]), onNext(210, (object) ['prop' => 2]), onNext(240, (object) ['prop' => 3]), onNext(290, new \stdClass()), onNext(350, (object) ['prop' => 5]), onError(400, new \Exception())]);
     $results = $this->scheduler->startWithCreate(function () use($xs) {
         return $xs->pluck('prop');
     });
     $this->assertMessages([onNext(210, 2), onNext(240, 3), onError(290, new \Exception())], $results->getMessages());
     $this->assertSubscriptions([subscribe(200, 290)], $xs->getSubscriptions());
 }
开发者ID:ReactiveX,项目名称:RxPHP,代码行数:12,代码来源:PluckTest.php


示例9: bufferWithCountError

 /**
  * @test
  */
 public function bufferWithCountError()
 {
     $error = new \Exception();
     $xs = $this->createHotObservable([onNext(150, 1), onNext(210, 2), onNext(220, 3), onNext(230, 4), onNext(240, 5), onError(250, $error)]);
     $results = $this->scheduler->startWithCreate(function () use($xs) {
         return $xs->bufferWithCount(5);
     });
     $this->assertMessages([onError(250, $error)], $results->getMessages());
 }
开发者ID:ReactiveX,项目名称:RxPHP,代码行数:12,代码来源:BufferWithCountTest.php


示例10: start_with_error

 /**
  * @test
  */
 public function start_with_error()
 {
     $error = new \Exception();
     $results = $this->scheduler->startWithCreate(function () use($error) {
         return Observable::start(function () use($error) {
             throw $error;
         }, $this->scheduler);
     });
     $this->assertMessages([onError(200, $error)], $results->getMessages());
 }
开发者ID:voryx,项目名称:Rx.PHP,代码行数:13,代码来源:StartTest.php


示例11: subscribeOn_error

 /**
  * @test
  */
 public function subscribeOn_error()
 {
     $error = new \Exception();
     $xs = $this->createHotObservable([onNext(150, 1), onError(210, $error)]);
     $results = $this->scheduler->startWithCreate(function () use($xs) {
         return $xs->subscribeOn($this->scheduler);
     });
     $this->assertMessages([onError(210, $error)], $results->getMessages());
     $this->assertSubscriptions([subscribe(201, 211)], $xs->getSubscriptions());
 }
开发者ID:voryx,项目名称:Rx.PHP,代码行数:13,代码来源:SubscribeOnTest.php


示例12: calls_on_error_if_predicate_throws_an_exception

 /**
  * @test
  */
 public function calls_on_error_if_predicate_throws_an_exception()
 {
     $xs = $this->createHotObservable(array(onNext(500, 42)));
     $results = $this->scheduler->startWithCreate(function () use($xs) {
         return $xs->where(function () {
             throw new Exception();
         });
     });
     $this->assertMessages(array(onError(500, new Exception())), $results->getMessages());
 }
开发者ID:Gasperowicz,项目名称:Rx.PHP,代码行数:13,代码来源:WhereTest.php


示例13: throttle_error

 /**
  * @test
  */
 public function throttle_error()
 {
     $error = new \Exception();
     $xs = $this->createHotObservable([onNext(150, 1), onNext(210, 2), onNext(250, 3), onNext(310, 4), onNext(350, 5), onError(410, $error), onNext(450, 7), onCompleted(500)]);
     $results = $this->scheduler->startWithCreate(function () use($xs) {
         return $xs->throttle(200);
     });
     $this->assertMessages([onNext(210, 2), onError(410, $error)], $results->getMessages());
     $this->assertSubscriptions([subscribe(200, 410)], $xs->getSubscriptions());
 }
开发者ID:ReactiveX,项目名称:RxPHP,代码行数:13,代码来源:ThrottleTest.php


示例14: generator_throws_error

 /**
  * @test
  */
 public function generator_throws_error()
 {
     $error = new \Exception();
     $generator = $this->genError($error);
     $xs = new \Rx\Observable\IteratorObservable($generator);
     $results = $this->scheduler->startWithCreate(function () use($xs) {
         return $xs;
     });
     $this->assertMessages([onError(201, $error)], $results->getMessages());
 }
开发者ID:voryx,项目名称:Rx.PHP,代码行数:13,代码来源:IteratorObservableTest.php


示例15: testToArrayError

 public function testToArrayError()
 {
     $error = new \Exception();
     $xs = $this->createHotObservable([onNext(110, 1), onNext(220, 2), onNext(330, 3), onNext(440, 4), onNext(550, 5), onError(660, $error)]);
     /** @var MockObserver $results */
     $results = $this->scheduler->startWithCreate(function () use($xs) {
         return $xs->toArray();
     });
     $this->assertMessages([onError(660, $error)], $results->getMessages());
     $this->assertSubscriptions([subscribe(200, 660)], $xs->getSubscriptions());
 }
开发者ID:bluetechy,项目名称:Rx.PHP,代码行数:11,代码来源:ToArrayTest.php


示例16: flatMapTo_it_passes_on_error

 /**
  * @test
  */
 public function flatMapTo_it_passes_on_error()
 {
     $xs = $this->createColdObservable(array(onNext(100, 4), onNext(200, 2), onNext(300, 3), onNext(400, 1), onCompleted(510)));
     $ys = $this->createColdObservable(array(onNext(50, 'foo'), onNext(100, 'bar'), onNext(150, 'baz'), onError(210, new Exception()), onCompleted(250)));
     $results = $this->scheduler->startWithCreate(function () use($xs, $ys) {
         return $xs->flatMapTo($ys);
     });
     $this->assertMessages(array(onNext(350, "foo"), onNext(400, "bar"), onNext(450, "baz"), onNext(450, "foo"), onNext(500, "bar"), onError(510, new Exception())), $results->getMessages());
     $this->assertSubscriptions(array(subscribe(200, 510)), $xs->getSubscriptions());
     $this->assertSubscriptions(array(subscribe(300, 510), subscribe(400, 510), subscribe(500, 510)), $ys->getSubscriptions());
 }
开发者ID:ReactiveX,项目名称:RxPHP,代码行数:14,代码来源:SelectManyTest.php


示例17: doOnError_should_call_after_resubscription

 /**
  * @test
  */
 public function doOnError_should_call_after_resubscription()
 {
     $xs = $this->createColdObservable([onError(10, new \Exception("Hello")), onCompleted(20)]);
     $messages = [];
     $xs->doOnError(function ($x) use(&$messages) {
         $messages[] = onError($this->scheduler->getClock(), $x);
     })->retry(2)->subscribeCallback(null, function () {
     }, null, $this->scheduler);
     $this->scheduler->start();
     $this->assertMessages([onError(10, new \Exception("Hello")), onError(20, new \Exception("Hello"))], $messages);
 }
开发者ID:ReactiveX,项目名称:RxPHP,代码行数:14,代码来源:DoOnErrorTest.php


示例18: testSkipUntilNeverError

 public function testSkipUntilNeverError()
 {
     $error = new \Exception();
     $l = Observable::never();
     $r = $this->createHotObservable([onNext(150, 1), onError(225, $error)]);
     /** @var MockObserver $results */
     $results = $this->scheduler->startWithCreate(function () use($l, $r) {
         return $l->skipUntil($r);
     });
     $this->assertMessages([onError(225, $error)], $results->getMessages());
 }
开发者ID:ReactiveX,项目名称:RxPHP,代码行数:11,代码来源:SkipUntilTest.php


示例19: it_passes_on_error_from_sources

 /**
  * @test
  */
 public function it_passes_on_error_from_sources()
 {
     $xs = $this->createColdObservable(array(onNext(100, 4), onNext(200, 2), onNext(300, 3), onNext(400, 1), onCompleted(500)));
     $ys = $this->createColdObservable(array(onNext(50, $xs), onError(200, new Exception()), onCompleted(250)));
     $results = $this->scheduler->startWithCreate(function () use($ys) {
         return Observable::mergeAll($ys);
     });
     $this->assertMessages(array(onNext(350, 4), onError(400, new Exception())), $results->getMessages());
     $this->assertSubscriptions(array(subscribe(250, 400)), $xs->getSubscriptions());
     $this->assertSubscriptions(array(subscribe(200, 400)), $ys->getSubscriptions());
 }
开发者ID:voryx,项目名称:Rx.PHP,代码行数:14,代码来源:MergeAllTest.php


示例20: defer_throw

 /**
  * @test
  */
 public function defer_throw()
 {
     $invoked = 0;
     $results = $this->scheduler->startWithCreate(function () use(&$invoked) {
         return BaseObservable::defer(function () use(&$invoked) {
             $invoked++;
             throw new \Exception('error');
         });
     });
     $this->assertMessages([onError(200, new \Exception('error'))], $results->getMessages());
     $this->assertEquals(1, $invoked);
 }
开发者ID:Katakeyni,项目名称:Rx.PHP,代码行数:15,代码来源:DeferTest.php



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


鲜花

握手

雷人

路过

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

请发表评论

全部评论

专题导读
上一篇:
PHP on_page函数代码示例发布时间:2022-05-15
下一篇:
PHP onCompleted函数代码示例发布时间:2022-05-15
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

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

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

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