Observable using create

create is an important method to create Observable. Below are few points which make Observable using create interesting

Creates from scratch

observer methods are programmatically written

emitter method is provided for interfaces to use

Below is the code which can help you to understand creating Observable using create method.

https://gist.github.com/CODINGSAINT/97f69898c3d3dcf6e1cf1669ebb1bdee

Here we are trying to create Observable using create method where we get 15 different shapes. The create method provides a subscribe method where we are iterating each elements from list and emitting one by one. The emitted events are listened on DemoSubscriber.

For RxUtil.java class and DemoSubscriber and for full code you can refer git library : https://github.com/CODINGSAINT/rxJava-tutorial

Now once you run it you will get following output

Observable using create

Comments

Java

Observable using defer

More from this blog

Spring AI Tool Calling: From Chatbot to AI Agent with @Tool

Spring AI Advisors API in Java: Build Middleware for AI Interactions

Working with Multiple AI Models in Spring AI — @Qualifier, mutate(), and Model Routing

Spring AI ChatClient API: The Fluent Heart of AI Integration

What is Spring AI? — Why Java Developers Need This in 2026

Command Palette

Comments

Java

Observable using defer

More from this blog