MCPcopy Create free account

hub / github.com/PacktPublishing/Hands-On-Reactive-Programming-in-Spring-5 / functions

Functions735 in github.com/PacktPublishing/Hands-On-Reactive-Programming-in-Spring-5

⨍ Functions 735◇ Types & classes 302
↓ 71 callersMethodsubscribe
(Subscriber<? super News> s)
chapter-03/news-service/src/main/java/org/rpis5/chapters/chapter_03/news_service/DBPublisher.java:22
↓ 50 callersMethodget
(ServerRequest request)
chapter-06/functional-spring-boot/src/main/java/org/rpis5/chapters/chapter_06/functional/springboot/OrderHandler.java:31
↓ 23 callersMethodsave
(Order order)
chapter-06/functional-spring-boot/src/main/java/org/rpis5/chapters/chapter_06/functional/springboot/OrderRepository.java:10
↓ 21 callersMethodfrom
(GitterProperties.GenericProperties gitterProperties)
chapter-08/cloud-stream/src/main/java/com/example/service/gitter/GitterUriBuilder.java:11
↓ 19 callersMethodof
(String title, Integer publishingYear)
chapter-07/section-10-rxjava2-jdbc/src/main/java/org/rpis5/chapters/chapter_07/rxjava2jdbc/book/Book.java:15
↓ 16 callersMethodrun
(String... args)
chapter-07/section-02-jpa/src/main/java/org/rpis5/chapters/chapter_07/jpa/Chapter7JpaApplication.java:30
↓ 15 callersMethodadd
(InnerSubscription subscription)
chapter-03/news-service/src/main/java/org/rpis5/chapters/chapter_03/news_service/SmartMulticastProcessor.java:96
↓ 15 callersMethodbody
(BodyExtractor<T, ? super ClientHttpResponse> extractor)
chapter-09/src/test/java/org/rpis5/chapters/chapter_09/MockClientResponse.java:83
↓ 15 callersMethodrequest
(long n, Object instance, AtomicLongFieldUpdater updater)
chapter-03/news-service/src/main/java/org/rpis5/chapters/chapter_03/news_service/SubscriptionUtils.java:21
↓ 13 callersMethodgetId
()
chapter-06/samples/src/main/java/org/rpis5/chapters/chapter_06/sse/StockItem.java:8
↓ 11 callersMethodcreate
(int statusCode, Publisher body)
chapter-09/src/test/java/org/rpis5/chapters/chapter_09/MockClientResponse.java:29
↓ 10 callersMethodfindAll
()
chapter-07/section-01-jdbc/src/main/java/org/rpis5/chapters/chapter_07/jdbc/BookJdbcRepository.java:43
↓ 10 callersMethodonNext
(T next)
chapter-02/src/main/java/org/rpis5/chapters/chapter_02/observer/RxObserver.java:4
↓ 10 callersMethodstream
()
chapter-03/vert.x/src/main/java/org/rpis5/chapters/chapter_03/vert/x/LogService.java:6
↓ 10 callersMethodtitle
()
chapter-07/section-10-rxjava2-jdbc/src/main/java/org/rpis5/chapters/chapter_07/rxjava2jdbc/book/Book.java:12
↓ 9 callersMethodcount
()
chapter-07/section-09-rx-sync/src/main/java/org/rpis5/chapters/chapter_07/wrapped_sync/ReactiveCrudRepositoryAdapter.java:99
↓ 9 callersMethodgetCollection
()
chapter-08/dataflow/mongodb-processor/src/main/java/org/rpis5/chapters/chapter_08/dataflow/mongodb/processor/MongodbProcessorProperties.java:48
↓ 9 callersMethodonError
(Exception e)
chapter-02/src/main/java/org/rpis5/chapters/chapter_02/observer/RxObserver.java:6
↓ 9 callersMethodreportResults
(String message, Flux<Book> books)
chapter-07/section-04-rx-mongo/src/main/java/org/rpis5/chapters/chapter_07/mongo_rx_tx/Chapter7RxMongoApplication.java:84
↓ 8 callersMethodfindOneByTitle
(Mono<String> title)
chapter-07/section-04-rx-mongo/src/main/java/org/rpis5/chapters/chapter_07/mongo_rx_tx/BookSpringDataMongoRxRepository.java:17
↓ 8 callersMethodgetMessage
()
chapter-06/samples/src/main/java/org/rpis5/chapters/chapter_06/json/Message.java:7
↓ 8 callersMethodgetName
()
chapter-03/news-service/src/main/java/org/rpis5/chapters/chapter_03/news_service/NamedSubscriber.java:4
↓ 8 callersMethodtoString
(Iterable<Book> books)
chapter-07/section-02-jpa/src/main/java/org/rpis5/chapters/chapter_07/jpa/Chapter7JpaApplication.java:52
↓ 8 callersMethodtoString
(Stream<Book> books)
chapter-07/section-01-jdbc/src/main/java/org/rpis5/chapters/chapter_07/jdbc/Chapter7JdbcApplication.java:99
↓ 7 callersMethodexecute
(Runnable command)
chapter-10/src/main/java/org/rpis5/chapters/chapter_10/scheduler/MeteredSchedulersFactory.java:37
↓ 7 callersMethodonComplete
()
chapter-02/src/main/java/org/rpis5/chapters/chapter_02/observer/RxObserver.java:5
↓ 7 callersMethodremove
(InnerSubscription subscription)
chapter-03/news-service/src/main/java/org/rpis5/chapters/chapter_03/news_service/SmartMulticastProcessor.java:125
↓ 7 callersMethodsend
(Mono<Payment> payment)
chapter-09/src/main/java/org/rpis5/chapters/chapter_09/PaymentService.java:10
↓ 6 callersMethodcancel
()
chapter-03/news-service/src/main/java/org/rpis5/chapters/chapter_03/news_service/ScheduledPublisher.java:84
↓ 6 callersMethodcontentType
()
chapter-09/src/test/java/org/rpis5/chapters/chapter_09/MockClientResponse.java:141
↓ 6 callersMethodfindById
(String id)
chapter-06/functional-spring-boot/src/main/java/org/rpis5/chapters/chapter_06/functional/springboot/OrderRepository.java:8
↓ 6 callersMethodmeterName
(String s)
chapter-10/src/main/java/org/rpis5/chapters/chapter_10/scheduler/MeteredScheduledThreadPoolExecutor.java:72
↓ 6 callersMethodnotifyObservers
(String event)
chapter-02/src/main/java/org/rpis5/chapters/chapter_02/observer/ConcreteSubject.java:18
↓ 6 callersMethodobserve
(T event)
chapter-02/src/main/java/org/rpis5/chapters/chapter_02/observer/Observer.java:4
↓ 5 callersMethodaccept
(OutputFrame outputFrame)
chapter-07/section-06-r2dbc/src/main/java/org/rpis5/chapters/chapter_07/r2dbs/PostgresConfiguration.java:27
↓ 5 callersMethodbalance
()
chapter-07/section-10-rxjava2-jdbc/src/main/java/org/rpis5/chapters/chapter_07/rxjava2jdbc/wallet/WalletData.java:10
↓ 5 callersMethodcancel
()
chapter-03/push.vs.pull/src/main/java/org/rpis5/chapters/chapter_03/push_pull_model/TakeFilterOperator.java:162
↓ 5 callersMethodclose
()
chapter-04/src/test/java/org/rpis5/chapters/chapter_04/ReactorEssentialsTest.java:671
↓ 5 callersMethodcookies
()
chapter-09/src/test/java/org/rpis5/chapters/chapter_09/MockClientResponse.java:63
↓ 5 callersMethodcreate
(ServerRequest request)
chapter-06/functional-spring-boot/src/main/java/org/rpis5/chapters/chapter_06/functional/springboot/OrderHandler.java:21
↓ 5 callersMethodheaders
()
chapter-09/src/test/java/org/rpis5/chapters/chapter_09/MockClientResponse.java:58
↓ 5 callersMethodreportResults
(String message, Publisher<Book> books)
chapter-07/section-10-rxjava2-jdbc/src/main/java/org/rpis5/chapters/chapter_07/rxjava2jdbc/Chapter7RxJava2JdbcApplication.java:62
↓ 5 callersMethodstart
()
chapter-03/vert.x/src/main/java/org/rpis5/chapters/chapter_03/vert/x/VertxDemoApp.java:13
↓ 4 callersMethodbodyToFlux
(Class<? extends T> elementClass)
chapter-09/src/test/java/org/rpis5/chapters/chapter_09/MockClientResponse.java:98
↓ 4 callersMethodbodyToMono
(Class<? extends T> elementClass)
chapter-09/src/test/java/org/rpis5/chapters/chapter_09/MockClientResponse.java:88
↓ 4 callersMethodcalculate
(Input value)
chapter-01/src/main/java/org/rpis5/chapters/chapter_01/futures/ShoppingCardService.java:9
↓ 4 callersMethoddelegate
()
chapter-09/src/test/java/org/rpis5/chapters/chapter_09/MockClientResponse.java:132
↓ 4 callersMethoddeposits
()
chapter-07/section-10-rxjava2-jdbc/src/main/java/org/rpis5/chapters/chapter_07/rxjava2jdbc/wallet/WalletData.java:13
↓ 4 callersMethodid
()
chapter-07/section-10-rxjava2-jdbc/src/main/java/org/rpis5/chapters/chapter_07/rxjava2jdbc/book/Book.java:11
↓ 4 callersMethodinput
()
chapter-08/cloud-stream/src/main/java/com/example/controller/InfoResource.java:67
↓ 4 callersMethodlist
(int count)
chapter-03/push.vs.pull/src/main/java/org/rpis5/chapters/chapter_03/push_model/Puller.java:9
↓ 4 callersMethodmongoClient
()
chapter-03/news-service/src/test/java/org/rpis5/chapters/chapter_03/WithEmbeddedMongo.java:51
↓ 4 callersMethodonComplete
()
chapter-03/push.vs.pull/src/main/java/org/rpis5/chapters/chapter_03/push_pull_model/TakeFilterOperator.java:138
↓ 4 callersMethodprintCurrentContext
(String id)
chapter-04/src/test/java/org/rpis5/chapters/chapter_04/ReactiveContextTest.java:29
↓ 4 callersMethodregisterObserver
(Observer<String> observer)
chapter-02/src/main/java/org/rpis5/chapters/chapter_02/observer/ConcreteSubject.java:10
↓ 4 callersMethodremoveAllClients
()
chapter-07/section-05-rx-mongo-tx/src/main/java/org/rpis5/chapters/chapter_07/mongo_rx_tx/wallet/WalletService.java:20
↓ 4 callersMethodsaveAll
(Iterable<S> entities)
chapter-07/section-09-rx-sync/src/main/java/org/rpis5/chapters/chapter_07/wrapped_sync/ReactiveCrudRepositoryAdapter.java:26
↓ 4 callersMethodstart
()
chapter-07/section-05-rx-mongo-tx/src/test/java/org/rpis5/chapters/chapter_07/mongo_rx_tx/wallet/BaseWalletServiceTest.java:145
↓ 4 callersMethodsubscribe
(Subscriber s)
chapter-03/push.vs.pull/src/main/java/org/rpis5/chapters/chapter_03/push_pull_model/TakeFilterOperator.java:25
↓ 4 callersMethodwithdraws
()
chapter-07/section-10-rxjava2-jdbc/src/main/java/org/rpis5/chapters/chapter_07/rxjava2jdbc/wallet/WalletData.java:14
↓ 3 callersMethoddelete
(T entity)
chapter-07/section-09-rx-sync/src/main/java/org/rpis5/chapters/chapter_07/wrapped_sync/ReactiveCrudRepositoryAdapter.java:123
↓ 3 callersMethodfindByPublishingYearBetweenOrderByPublishingYear
( Integer from, Integer to, Pageable pageable )
chapter-07/section-04-rx-mongo/src/main/java/org/rpis5/chapters/chapter_07/mongo_rx_tx/BookSpringDataMongoRxRepository.java:27
↓ 3 callersMethodgenerate
()
chapter-03/news-service/src/test/java/org/rpis5/chapters/chapter_03/news_service/NewsHarness.java:11
↓ 3 callersMethodgetValue
()
chapter-02/src/main/java/org/rpis5/chapters/chapter_02/rx_app/Temperature.java:13
↓ 3 callersMethodhasEnoughFunds
(int amount)
chapter-07/section-05-rx-mongo-tx/src/main/java/org/rpis5/chapters/chapter_07/mongo_rx_tx/wallet/Wallet.java:25
↓ 3 callersMethodindex
(Model model)
chapter-08/cloud-stream/src/main/java/com/example/controller/ChatController.java:17
↓ 3 callersMethodinitMongoNode
(int exposePort)
chapter-07/section-05-rx-mongo-tx/src/test/java/org/rpis5/chapters/chapter_07/mongo_rx_tx/wallet/TransactionalWalletServiceTest.java:63
↓ 3 callersMethodisTerminated
()
chapter-03/news-service/src/main/java/org/rpis5/chapters/chapter_03/news_service/SmartMulticastProcessor.java:160
↓ 3 callersMethodonError
(Throwable throwable)
chapter-03/news-service/src/main/java/org/rpis5/chapters/chapter_03/news_service/ScheduledPublisher.java:113
↓ 3 callersMethodowner
()
chapter-07/section-10-rxjava2-jdbc/src/main/java/org/rpis5/chapters/chapter_07/rxjava2jdbc/wallet/WalletData.java:9
↓ 3 callersMethodprocess
()
chapter-01/src/main/java/org/rpis5/chapters/chapter_01/callbacks/OrdersService.java:12
↓ 3 callersMethodreportResults
(String message, Flux<Book> books)
chapter-07/section-09-rx-sync/src/main/java/org/rpis5/chapters/chapter_07/wrapped_sync/Chapter7JpaApplication.java:60
↓ 3 callersMethodstatusCode
()
chapter-09/src/test/java/org/rpis5/chapters/chapter_09/MockClientResponse.java:48
↓ 3 callersMethodsubmit
(Callable<T> task)
chapter-10/src/main/java/org/rpis5/chapters/chapter_10/scheduler/MeteredSchedulersFactory.java:68
↓ 3 callersMethodsubscribe
(Subscriber<? super T> actual)
chapter-03/news-service/src/main/java/org/rpis5/chapters/chapter_03/news_service/ScheduledPublisher.java:42
↓ 3 callersMethodtearDownMongo
()
chapter-03/news-service/src/test/java/org/rpis5/chapters/chapter_03/WithEmbeddedMongo.java:46
↓ 3 callersMethodtoString
()
chapter-06/samples/src/main/java/org/rpis5/chapters/chapter_06/json/Message.java:15
↓ 3 callersMethodtoString
(Iterable<Book> books)
chapter-07/section-03-mongo/src/main/java/org/rpis5/chapters/chapter_07/mongo_repo/Chapter7RxMongoApplication.java:48
↓ 3 callersMethodtryDrain
()
chapter-03/news-service/src/main/java/org/rpis5/chapters/chapter_03/news_service/SmartMulticastProcessor.java:285
↓ 2 callersMethodasHttpHeaders
()
chapter-09/src/test/java/org/rpis5/chapters/chapter_09/MockClientResponse.java:152
↓ 2 callersMethodcancel
(boolean mayInterruptIfRunning)
chapter-03/async.vs.reactive/src/main/java/org/rpis5/chapters/chapter_03/async_vs_reactive/PublisherAsCompletableFuture.java:29
↓ 2 callersMethodconnectionFactory
(DatabaseLocation databaseLocation)
chapter-07/section-06-r2dbc/src/main/java/org/rpis5/chapters/chapter_07/r2dbs/InfrastructureConfiguration.java:49
↓ 2 callersMethoddeleteById
(String id)
chapter-06/functional-spring-boot/src/main/java/org/rpis5/chapters/chapter_06/functional/springboot/OrderRepository.java:12
↓ 2 callersMethoddeposit
(int amount)
chapter-07/section-05-rx-mongo-tx/src/main/java/org/rpis5/chapters/chapter_07/mongo_rx_tx/wallet/Wallet.java:37
↓ 2 callersMethoddrain
()
chapter-03/news-service/src/main/java/org/rpis5/chapters/chapter_03/news_service/NewsPreparationOperator.java:115
↓ 2 callersMethoddrain
(Subscriber<T> a, long r)
chapter-03/push.vs.pull/src/main/java/org/rpis5/chapters/chapter_03/push_pull_model/TakeFilterOperator.java:171
↓ 2 callersMethodemit
(T e)
chapter-03/news-service/src/main/java/org/rpis5/chapters/chapter_03/news_service/ScheduledPublisher.java:139
↓ 2 callersMethodeventuallyReadDigest
()
chapter-03/news-service/src/main/java/org/rpis5/chapters/chapter_03/news_service/NewsServiceSubscriber.java:55
↓ 2 callersMethodfindAll
()
chapter-07/section-10-rxjava2-jdbc/src/main/java/org/rpis5/chapters/chapter_07/rxjava2jdbc/book/RxBookRepository.java:49
↓ 2 callersMethodfindBooksByTitle
(String title, boolean negate)
chapter-07/section-04-rx-mongo/src/main/java/org/rpis5/chapters/chapter_07/mongo_rx_tx/RxMongoDriverQueryService.java:27
↓ 2 callersMethodfindByIdBetween
(int lower, int upper)
chapter-07/section-09-rx-sync/src/main/java/org/rpis5/chapters/chapter_07/wrapped_sync/BookJpaRepository.java:11
↓ 2 callersMethodfindByOwner
(Mono<String> owner)
chapter-07/section-05-rx-mongo-tx/src/main/java/org/rpis5/chapters/chapter_07/mongo_rx_tx/wallet/WalletRepository.java:12
↓ 2 callersMethodgenerateClients
(Integer number, Integer defaultBalance)
chapter-07/section-05-rx-mongo-tx/src/main/java/org/rpis5/chapters/chapter_07/mongo_rx_tx/wallet/WalletService.java:11
↓ 2 callersMethodgetCollectionExpression
()
chapter-08/dataflow/mongodb-processor/src/main/java/org/rpis5/chapters/chapter_08/dataflow/mongodb/processor/MongodbProcessorProperties.java:56
↓ 2 callersMethodgetData
()
chapter-04/src/test/java/org/rpis5/chapters/chapter_04/ReactorEssentialsTest.java:664
↓ 2 callersMethodgetOrDeducePassword
( String password, PasswordEncoder encoder )
chapter-06/security-samples/src/main/java/org/rpis5/chapters/chapter_06/security/SecurityConfiguration.java:56
↓ 2 callersMethodgetRecipient
()
chapter-03/news-service/src/main/java/org/rpis5/chapters/chapter_03/news_service/SmartMulticastProcessor.java:212
↓ 2 callersMethodgetStreamOfItems
()
chapter-03/push.vs.pull/src/main/java/org/rpis5/chapters/chapter_03/push_model/AsyncDatabaseClient.java:7
↓ 2 callersMethodhash
(Object key)
chapter-03/news-service/src/main/java/org/rpis5/chapters/chapter_03/news_service/SmartMulticastProcessor.java:164
↓ 2 callersMethodisValid
(String userId)
chapter-04/src/test/java/org/rpis5/chapters/chapter_04/ReactorEssentialsTest.java:633
next →1–100 of 735, ranked by callers