How do I use dependency injection in Spring?

In Spring, Dependency Injection (DI) means you let the Spring container create and provide the objects your class depends on, instead of manually creating them with new.

The recommended approach in modern Spring is constructor injection.

1. Define a dependency as a Spring bean

import org.springframework.stereotype.Component;

@Component
public class EmailSender {

    public void send(String message) {
        System.out.println("Sending email: " + message);
    }
}

@Component tells Spring: “Create and manage an instance of this class.”

2. Inject it into another bean

import org.springframework.stereotype.Service;

@Service
public class NotificationService {

    private final EmailSender emailSender;

    public NotificationService(EmailSender emailSender) {
        this.emailSender = emailSender;
    }

    public void notifyUser(String message) {
        emailSender.send(message);
    }
}

Because NotificationService is also a Spring bean, Spring sees its constructor and automatically provides an EmailSender.

In modern Spring, if there is only one constructor, you usually do not need @Autowired on the constructor.

3. Use the service from a controller or another bean

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class NotificationController {

    private final NotificationService notificationService;

    public NotificationController(NotificationService notificationService) {
        this.notificationService = notificationService;
    }

    @GetMapping("/notify")
    public String notifyUser() {
        notificationService.notifyUser("Hello from Spring!");
        return "Notification sent";
    }
}

Common DI styles in Spring

Constructor injection — recommended

@Service
public class MyService {

    private final MyDependency myDependency;

    public MyService(MyDependency myDependency) {
        this.myDependency = myDependency;
    }
}

Use this most of the time because it:

  • makes dependencies explicit
  • supports immutability with final
  • is easier to test
  • avoids partially initialized objects

Setter injection

@Service
public class MyService {

    private MyDependency myDependency;

    @Autowired
    public void setMyDependency(MyDependency myDependency) {
        this.myDependency = myDependency;
    }
}

Use setter injection mainly for optional dependencies or dependencies that may change after construction.

Field injection — usually avoid

@Service
public class MyService {

    @Autowired
    private MyDependency myDependency;
}

This works, but it is generally discouraged because it makes testing harder and hides the class’s required dependencies.

Injecting interfaces

A common pattern is to inject an interface rather than a concrete class:

public interface MessageSender {
    void send(String message);
}
import org.springframework.stereotype.Component;

@Component
public class EmailSender implements MessageSender {

    @Override
    public void send(String message) {
        System.out.println("Email: " + message);
    }
}
import org.springframework.stereotype.Service;

@Service
public class NotificationService {

    private final MessageSender messageSender;

    public NotificationService(MessageSender messageSender) {
        this.messageSender = messageSender;
    }

    public void notifyUser(String message) {
        messageSender.send(message);
    }
}

If there is only one implementation of MessageSender, Spring injects it automatically.

When there are multiple implementations

If multiple beans match the same type, use @Qualifier:

import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Service;

@Service
public class NotificationService {

    private final MessageSender messageSender;

    public NotificationService(@Qualifier("emailSender") MessageSender messageSender) {
        this.messageSender = messageSender;
    }
}

The qualifier value usually matches the bean name, which by default is the class name with a lowercase-first letter.

Creating beans with @Bean

You can also define beans in a configuration class:

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class AppConfig {

    @Bean
    public EmailSender emailSender() {
        return new EmailSender();
    }
}

This is useful when:

  • the class comes from a third-party library
  • construction requires custom setup
  • you do not want to annotate the class with @Component

Summary

Use this pattern most of the time:

@Service
public class MyService {

    private final MyDependency myDependency;

    public MyService(MyDependency myDependency) {
        this.myDependency = myDependency;
    }

    public void doWork() {
        myDependency.doSomething();
    }
}

And make sure the dependency is a Spring bean:

@Component
public class MyDependency {

    public void doSomething() {
        System.out.println("Dependency logic executed.");
    }
}

In short: annotate your classes with Spring stereotypes like @Component, @Service, or @Repository, then inject dependencies through constructors.

How do I understand what the Spring Framework actually does?

The easiest way to understand what the Spring Framework actually does is to stop thinking of it as “magic” and start thinking of it as infrastructure code that your application delegates to.

At a high level:

Spring creates objects, wires them together, manages their lifecycle, and adds common behavior around them so you do not have to write that plumbing yourself.


1. The Core Problem Spring Solves

Without Spring, your application code often has to manually do things like:

UserRepository repository = new JdbcUserRepository(dataSource);
EmailService emailService = new SmtpEmailService(config);
UserService userService = new UserService(repository, emailService);

As the application grows, this becomes harder to manage:

  • Who creates each object?
  • In what order?
  • Which implementation should be used?
  • How are shared dependencies reused?
  • How do you add transactions, security, logging, validation, configuration, etc.?

Spring’s answer is:

Declare your application components, and I will create, connect, configure, and enhance them.


2. Spring Is Mainly an Application Container

The heart of Spring is the IoC container.

IoC means Inversion of Control.

Instead of your code controlling object creation:

UserService service = new UserService(new UserRepository());

Spring controls it:

@Service
public class UserService {

    private final UserRepository userRepository;

    public UserService(UserRepository userRepository) {
        this.userRepository = userRepository;
    }
}

Then Spring sees:

@Repository
public class UserRepository {
}

And automatically creates:

  • a UserRepository
  • a UserService
  • injects the repository into the service

This is called Dependency Injection.

So Spring’s first major job is:

Managing your application objects, called beans.


3. What Is a Bean?

A Spring bean is simply an object managed by Spring.

For example:

@Service
public class PaymentService {
}

That class becomes a Spring-managed object.

Spring can:

  • create it
  • inject its dependencies
  • configure it
  • call lifecycle methods
  • wrap it with proxies
  • destroy it when the application shuts down

The object itself is ordinary Java. What changes is who manages it.


4. Spring Reads Metadata About Your App

Spring needs to know what objects to manage.

You give it metadata using annotations such as:

@Component
@Service
@Repository
@Controller
@Configuration
@Bean
@Autowired

Example:

@Configuration
public class AppConfig {

    @Bean
    public Clock clock() {
        return Clock.systemUTC();
    }
}

This tells Spring:

“When something needs a Clock, use this object.”

Spring scans your code, reads these annotations, builds a registry of beans, and creates an application context.


5. The ApplicationContext Is the Running Spring Container

The ApplicationContext is basically Spring’s runtime environment.

It contains all managed beans.

Conceptually:

ApplicationContext context = ...;

UserService userService = context.getBean(UserService.class);

In most Spring applications, you do not usually call getBean() yourself. Spring injects dependencies automatically.

The container knows:

  • which beans exist
  • how to create them
  • what dependencies they need
  • what order to initialize them in
  • what configuration values they require

6. Spring Adds Behavior Using Proxies

A lot of Spring’s “magic” comes from proxies.

For example, when you write:

@Transactional
public void transferMoney(Account from, Account to, BigDecimal amount) {
    withdraw(from, amount);
    deposit(to, amount);
}

Spring does not rewrite your method.

Instead, it may create a wrapper object around your service.

Conceptually:

beginTransaction();

try {
    transferMoney(...);
    commitTransaction();
} catch (Exception ex) {
    rollbackTransaction();
    throw ex;
}

That wrapper is a proxy.

Spring uses proxies for features like:

  • transactions
  • security
  • caching
  • async methods
  • method validation
  • aspect-oriented programming

So another major thing Spring does is:

It intercepts calls to your objects and adds infrastructure behavior around them.


7. Spring MVC Handles Web Requests

If you use Spring MVC, Spring also acts as a web framework.

You write:

@RestController
@RequestMapping("/users")
public class UserController {

    @GetMapping("/{id}")
    public UserDto getUser(@PathVariable Long id) {
        return new UserDto(id, "Alice");
    }
}

Spring MVC handles:

  • receiving the HTTP request
  • matching /users/{id} to the method
  • converting path variables
  • calling your controller
  • converting the return value to JSON
  • writing the HTTP response

You focus on:

public UserDto getUser(Long id)

Spring handles the web plumbing.


8. Spring Data JPA Creates Repository Implementations

With Spring Data JPA, you can write:

public interface UserRepository extends JpaRepository<User, Long> {
    Optional<User> findByEmail(String email);
}

You do not manually implement this interface.

Spring Data creates an implementation at runtime.

It understands method names like:

findByEmail
findByStatus
findByCreatedAtAfter

And turns them into database queries.

So Spring Data JPA does:

  • repository implementation generation
  • query method parsing
  • transaction integration
  • JPA EntityManager management

9. Spring Boot vs Spring Framework

This is an important distinction.

Spring Framework

The Spring Framework provides the core capabilities:

  • dependency injection
  • bean lifecycle
  • transactions
  • Spring MVC
  • validation integration
  • resource loading
  • AOP
  • event system

Spring Boot

Spring Boot sits on top of Spring Framework.

It adds:

  • auto-configuration
  • embedded servers
  • starter dependencies
  • production features
  • simplified project setup

Spring Boot’s job is mostly:

“Based on what dependencies and settings you have, I will configure Spring automatically.”

For example, if Spring Boot sees Spring MVC on the classpath, it configures a web server and MVC infrastructure.

If it sees Spring Data JPA and a database driver, it configures JPA-related beans.


10. A Mental Model

Think of a Spring application like this:

Your code:
  Controllers
  Services
  Repositories
  Entities
  Configuration

Spring:
  Creates objects
  Injects dependencies
  Applies configuration
  Opens transactions
  Handles HTTP requests
  Converts JSON
  Manages validation
  Integrates with databases
  Publishes events
  Handles lifecycle

You write the business logic.

Spring handles the surrounding infrastructure.


11. What Happens at Startup?

Simplified startup flow:

1. Application starts
2. Spring creates an ApplicationContext
3. Spring scans classes and configuration
4. Spring discovers bean definitions
5. Spring creates beans
6. Spring injects dependencies
7. Spring applies post-processors
8. Spring creates proxies where needed
9. Web server starts, if this is a web app
10. App is ready to receive requests

For example:

@SpringBootApplication
public class MyApplication {

    public static void main(String[] args) {
        SpringApplication.run(MyApplication.class, args);
    }
}

That one line starts a large amount of framework infrastructure.


12. A Practical Way to Learn Spring

To understand Spring deeply, learn it in this order:

  1. Plain Java object creation
  2. Dependency Injection
  3. Beans and ApplicationContext
  4. Configuration with @Configuration and @Bean
  5. Component scanning with @Component, @Service, @Repository
  6. Bean lifecycle
  7. Spring MVC request handling
  8. Transactions with @Transactional
  9. Spring Data repositories
  10. Spring Boot auto-configuration

Avoid starting with everything at once. Spring feels magical when you learn MVC, JPA, transactions, Boot, security, and annotations simultaneously.


13. Tiny Example

Your code:

@Service
public class GreetingService {

    public String greet(String name) {
        return "Hello, " + name;
    }
}
@RestController
public class GreetingController {

    private final GreetingService greetingService;

    public GreetingController(GreetingService greetingService) {
        this.greetingService = greetingService;
    }

    @GetMapping("/hello")
    public String hello() {
        return greetingService.greet("World");
    }
}

What Spring does:

1. Finds GreetingService
2. Creates a GreetingService object
3. Finds GreetingController
4. Sees that it needs GreetingService
5. Injects GreetingService into GreetingController
6. Maps GET /hello to hello()
7. Calls hello() when an HTTP request arrives
8. Sends "Hello, World" as the response

That is Spring in miniature.


Bottom Line

Spring Framework mainly does four things:

  1. Object management
    It creates and manages your application objects.

  2. Dependency injection
    It wires objects together automatically.

  3. Infrastructure integration
    It provides transactions, web handling, validation, database integration, events, configuration, etc.

  4. Behavior wrapping
    It uses proxies to add behavior such as transactions, security, caching, and async execution.

The shortest explanation is:

Spring is a container and infrastructure framework that lets you write business code while it handles object creation, wiring, lifecycle, and common enterprise concerns.

How do I optimize performance and readability when using null safety in deeply nested data?

When working with deeply nested nullable data in Kotlin, the goal is to keep code both safe and understandable without building long, fragile chains or overusing !!.

1. Avoid very long safe-call chains when they hide meaning

This is safe:

val city = user?.profile?.address?.city ?: "Unknown"

For simple reads, that is perfectly fine.

But if the chain becomes long or has business meaning, split it into named intermediate values:

val profile = user?.profile
val address = profile?.address
val city = address?.city ?: "Unknown"

This is often easier to debug and read, especially when each level has meaning.

2. Prefer early returns for required nested values

If several nested values are required, avoid deeply nested let blocks:

fun sendEmail(user: User?) {
    val email = user?.profile?.contact?.email ?: return
    val name = user.profile.name ?: "there"

    emailService.send(to = email, subject = "Hello $name")
}

This is usually clearer than:

user?.profile?.contact?.email?.let { email ->
    user.profile.name?.let { name ->
        emailService.send(to = email, subject = "Hello $name")
    }
}

Use return, continue, break, or throw with Elvis when absence should stop processing:

val id = request?.user?.id ?: return
val token = request.auth?.token ?: throw IllegalArgumentException("Missing token")

3. Use let sparingly and name the value

let is useful when you want to run code only if a value is non-null. For nested data, avoid stacking anonymous its.

Prefer this:

user?.profile?.contact?.email?.let { email ->
    sendVerificationEmail(email)
}

Avoid this:

user?.let {
    it.profile?.let {
        it.contact?.let {
            it.email?.let {
                sendVerificationEmail(it)
            }
        }
    }
}

Nested it quickly becomes unreadable. Use explicit names:

user?.let { user ->
    user.profile?.let { profile ->
        profile.contact?.let { contact ->
            contact.email?.let { email ->
                sendVerificationEmail(email)
            }
        }
    }
}

Even then, if nesting grows, early returns are usually better.

4. Use defaults at the boundary

If your app can safely treat missing nested data as a default, normalize it early.

val displayName = user?.profile?.displayName ?: "Guest"
val avatarUrl = user?.profile?.avatarUrl ?: DEFAULT_AVATAR_URL
val roles = user?.permissions?.roles.orEmpty()

For collections, orEmpty() is especially readable:

for (order in user?.orders.orEmpty()) {
    process(order)
}

This avoids repeated null checks.

5. Convert messy external data into clean internal models

Deep nullability often comes from APIs, databases, JSON, or maps. Instead of spreading null handling throughout your code, convert once near the boundary.

data class ApiUser(
    val profile: ApiProfile?
)

data class ApiProfile(
    val displayName: String?,
    val email: String?
)

data class User(
    val displayName: String,
    val email: String?
)

fun ApiUser.toDomain(): User {
    return User(
        displayName = profile?.displayName ?: "Guest",
        email = profile?.email
    )
}

Then the rest of your code works with a cleaner model:

fun render(user: User) {
    println(user.displayName)
}

This improves both performance and readability because null checks are centralized.

6. Avoid !! in nested data

This is fragile:

val city = user!!.profile!!.address!!.city!!

It may be short, but it is not safe. If any level is null, it crashes with little context.

If the value is truly required, fail with a meaningful message:

val city = user?.profile?.address?.city
    ?: error("User city is required")

or:

val city = requireNotNull(user?.profile?.address?.city) {
    "User city is required"
}

Use this when null means a programmer error or invalid state.

7. Prefer mapNotNull and filterNotNull for nested collections

For nested nullable values in collections, avoid manual loops with multiple checks.

val emails = users
    .mapNotNull { user -> user.profile?.contact?.email }

For nullable lists:

val emails = users
    .orEmpty()
    .mapNotNull { user -> user.profile?.contact?.email }

For nullable elements:

val names = users
    .filterNotNull()
    .mapNotNull { user -> user.profile?.displayName }

This is concise and usually efficient enough for normal application code.

8. Be careful with repeated expensive calls

Safe-call chains are cheap when they access properties. But avoid repeating function calls that may be expensive or have side effects:

val city = repository.getUser()?.profile?.address?.city
val country = repository.getUser()?.profile?.address?.country

Better:

val address = repository.getUser()?.profile?.address
val city = address?.city
val country = address?.country

This improves performance and avoids inconsistent results if the function returns different data each time.

9. Use local variables to benefit from smart casts

Kotlin smart casts work best with stable local values.

val profile = user.profile

if (profile != null) {
    println(profile.displayName)
    println(profile.email)
}

This is often clearer than repeating:

println(user.profile?.displayName)
println(user.profile?.email)

Especially when you need several fields from the same nullable object.

10. For maps, distinguish missing keys from null values when needed

Nested maps can become confusing because a map lookup returns nullable values.

val city = users["ana"]?.get("address")?.get("city") ?: "Unknown"

This is fine if missing and null mean the same thing.

If they do not, check explicitly:

val userData = users["ana"]

if (userData != null && userData.containsKey("city")) {
    val city = userData["city"]
    println("City key exists with value: $city")
}

Practical rule of thumb

Use this progression:

  1. Simple optional read → safe-call chain
    val value = a?.b?.c ?: default
    
  2. Required value → Elvis with return, throw, or error
    val value = a?.b?.c ?: return
    
  3. Several fields from the same nullable object → local variable + null check
    val profile = user?.profile ?: return
    println(profile.name)
    println(profile.email)
    
  4. CollectionsorEmpty(), mapNotNull, filterNotNull
    val ids = users.orEmpty().mapNotNull { it.id }
    
  5. Deeply nullable external data → normalize into a cleaner model early
    val domainUser = apiUser.toDomain()
    

In short: safe-call chains are fine for simple reads, early returns are best for required nested data, named variables improve readability, and boundary mapping keeps null complexity from spreading through your code.

How do I use scope functions in a functional reactive context with Kotlin Flows?

In Kotlin Flow code, scope functions are useful, but they should usually play a supporting role. The main structure of your reactive pipeline should come from Flow operators such as map, filter, flatMapLatest, combine, onEach, catch, and stateIn.

A good rule of thumb:

Flow operators describe the stream.
Scope functions describe what you do with each value.

1. Use map for stream transformation, let for local value transformation

If you are transforming each emitted value, the outer operation should usually be map.

val userNames: Flow<String> =
    usersFlow.map { user ->
        user.let {
            "${it.firstName} ${it.lastName}"
        }
    }

In simple cases, let may be unnecessary:

val userNames: Flow<String> =
    usersFlow.map { user ->
        "${user.firstName} ${user.lastName}"
    }

Use let inside map when it clarifies a local transformation, especially for nullable values or multistep conversion.

val profileNames: Flow<String> =
    usersFlow.map { user ->
        user.profile?.let { profile ->
            profile.displayName
        } ?: "Anonymous"
    }

2. Use onEach for stream side effects, not also as the main Flow operator

For logging, analytics, caching, or debugging, prefer onEach.

val users: Flow<List<User>> =
    userRepository.users()
        .onEach { users ->
            logger.info("Loaded ${users.size} users")
        }

Inside a transformation, also can be fine when you want to return the same value after a local side effect:

val users: Flow<List<User>> =
    userRepository.users()
        .map { users ->
            users.filter { it.isActive }
                .also { activeUsers ->
                    logger.debug("Active users: ${activeUsers.size}")
                }
        }

But avoid using also where onEach expresses the intent better:

val users: Flow<List<User>> =
    userRepository.users()
        .onEach { logger.debug("Received users: $it") }
        .map { users -> users.filter { it.isActive } }

3. Use run when computing one result from an emitted object

run is useful when each emitted value needs a multistep computation.

val summaries: Flow<UserSummary> =
    usersFlow.map { user ->
        user.run {
            val fullName = "$firstName $lastName"
            val status = if (isActive) "active" else "inactive"

            UserSummary(
                id = id,
                name = fullName,
                status = status
            )
        }
    }

This works well when you want receiver-style access with this.

4. Use apply when constructing objects inside a Flow

apply is useful for configuring a mutable object before emitting or returning it.

val requests: Flow<Request> =
    userIds.map { userId ->
        Request().apply {
            method = "GET"
            path = "/users/$userId"
            headers["Accept"] = "application/json"
        }
    }

That said, in reactive code, immutable data classes are often clearer:

val requests: Flow<Request> =
    userIds.map { userId ->
        Request(
            method = "GET",
            path = "/users/$userId",
            headers = mapOf("Accept" to "application/json")
        )
    }

Use apply mainly when an API requires mutable configuration.

5. Use with sparingly inside Flow chains

with can be useful when working with an existing object, but nested receivers can become confusing inside Flow pipelines.

val messages: Flow<String> =
    events.map { event ->
        with(event.metadata) {
            "source=$source, timestamp=$timestamp"
        }
    }

This is fine if the receiver is obvious. But if you already have multiple nested lambdas, explicit names may be clearer:

val messages: Flow<String> =
    events.map { event ->
        val metadata = event.metadata
        "source=${metadata.source}, timestamp=${metadata.timestamp}"
    }

6. Be careful with nested it

Flow pipelines often contain nested lambdas. Scope functions can make that worse if every lambda uses implicit it.

Harder to read:

val result: Flow<List<String>> =
    usersFlow.map {
        it.filter {
            it.isActive
        }.map {
            it.name
        }
    }

Clearer:

val result: Flow<List<String>> =
    usersFlow.map { users ->
        users.filter { user ->
            user.isActive
        }.map { user ->
            user.name
        }
    }

This matters even more with scope functions:

val result: Flow<UserDto> =
    usersFlow.map { user ->
        user.profile?.let { profile ->
            UserDto(
                id = user.id,
                displayName = profile.displayName
            )
        } ?: UserDto(
            id = user.id,
            displayName = "Anonymous"
        )
    }

Prefer named lambda parameters when combining Flow operators and scope functions.

7. Use takeIf / takeUnless with care

Although not scope functions in the same group, takeIf and takeUnless often appear with let.

For simple filtering, prefer Flow’s filter:

val activeUsers: Flow<User> =
    usersFlow.filter { user ->
        user.isActive
    }

Instead of:

val activeUsers: Flow<User> =
    usersFlow.mapNotNull { user ->
        user.takeIf { it.isActive }
    }

But takeIf can be useful when a transformation may produce null:

val validEmails: Flow<String> =
    usersFlow.mapNotNull { user ->
        user.email
            ?.takeIf { email -> email.contains("@") }
            ?.lowercase()
    }

8. Use mapNotNull with let for nullable values

This is a widespread Flow pattern.

val avatars: Flow<Avatar> =
    usersFlow.mapNotNull { user ->
        user.avatarUrl?.let { url ->
            Avatar(url)
        }
    }

Or:

val displayNames: Flow<String> =
    usersFlow.mapNotNull { user ->
        user.profile?.displayName
    }

Use let when constructing a result from a nullable value is more involved.

9. Use flatMapLatest when the scope contains another Flow

If the transformation returns another Flow, do not use only let or map unless you intentionally want a nested Flow<Flow<T>>.

Usually:

val userDetails: Flow<UserDetails> =
    selectedUserId
        .filterNotNull()
        .flatMapLatest { userId ->
            userRepository.observeUserDetails(userId)
        }

If the ID is nullable, and you need fallback behavior:

val userDetails: Flow<UserDetails?> =
    selectedUserId.flatMapLatest { userId ->
        userId?.let {
            userRepository.observeUserDetails(it)
        } ?: flowOf(null)
    }

Here, let is handling the nullable value, while flatMapLatest handles the reactive flattening.

10. Prefer Flow operators for lifecycle and errors

Use catch, onStart, onCompletion, and retry rather than trying to encode those behaviors with scope functions.

val uiState: Flow<UiState> =
    userRepository.users()
        .map { users ->
            UiState.Success(users)
        }
        .onStart {
            emit(UiState.Loading)
        }
        .catch { throwable ->
            emit(UiState.Error(throwable.message ?: "Unknown error"))
        }

Scope functions can still help locally:

val uiState: Flow<UiState> =
    userRepository.users()
        .map { users ->
            users
                .filter { user -> user.isActive }
                .let { activeUsers -> UiState.Success(activeUsers) }
        }
        .onStart {
            emit(UiState.Loading)
        }
        .catch { throwable ->
            emit(UiState.Error(throwable.message ?: "Unknown error"))
        }

Practical mapping

Intent in Flow code Prefer Scope function role
Transform each emission map Use let/run inside if helpful
Remove nulls filterNotNull, mapNotNull Use let for nullable conversion
Side effect per emission onEach Use also only locally
Build/configure object map + constructor or apply apply for mutable setup
Switch to another Flow flatMapLatest, flatMapConcat, flatMapMerge Use let for nullable branch
Combine streams combine, zip Scope functions only inside result builder
Handle errors catch, retry Scope functions rarely needed
Emit loading state onStart Scope functions rarely needed

Example: realistic UI state pipeline

val uiState: StateFlow<UserUiState> =
    selectedUserId
        .filterNotNull()
        .flatMapLatest { userId ->
            userRepository.observeUser(userId)
        }
        .map { user ->
            user.run {
                UserUiState.Content(
                    id = id,
                    title = "$firstName $lastName",
                    subtitle = email ?: "No email"
                )
            }
        }
        .onEach { state ->
            analytics.logScreenState(state)
        }
        .catch { throwable ->
            emit(UserUiState.Error(throwable.message ?: "Unable to load user"))
        }
        .stateIn(
            scope = viewModelScope,
            started = SharingStarted.WhileSubscribed(5_000),
            initialValue = UserUiState.Loading
        )

Here:

  • filterNotNull handles nullable IDs.
  • flatMapLatest switches to the latest selected user stream.
  • run computes a UI model from a User.
  • onEach performs a side effect.
  • catch handles errors.
  • stateIn turns the cold flow into a StateFlow.

Main guideline

Use scope functions in Flow pipelines when they improve the readability of local value handling.

Avoid using them to replace Flow operators.

Good:
Flow operators for stream behavior.
Scope functions for per-value clarity.

Risky:
Long chains of map/let/also/run with nested it everywhere.

If the chain starts becoming hard to read, introduce named lambda parameters or local variables.

How do I avoid nullable types in complex data models using sealed classes and Result wrappers?

You can avoid “nullable everywhere” in complex data models by making missing/invalid/loading/error states explicit in the type system instead of representing them with null.

In Kotlin, the usual tools are:

  1. Sealed classes/interfaces for domain states and variants.
  2. Result<T>-style wrappers for success/failure.
  3. Non-nullable data classes for valid, fully constructed domain objects.
  4. Mapping layers from nullable external DTOs into safe domain models.

1. Avoid nullable domain fields

Instead of this:

data class User(
    val id: String?,
    val name: String?,
    val email: String?,
    val subscription: Subscription?
)

Prefer making the valid domain model non-nullable:

data class User(
    val id: UserId,
    val name: UserName,
    val email: Email,
    val subscription: SubscriptionState
)

@JvmInline
value class UserId(val value: String)

@JvmInline
value class UserName(val value: String)

@JvmInline
value class Email(val value: String)

Now User represents a valid user, not a partially valid object.


2. Use sealed classes for optional-like domain states

If a subscription can be absent, do not use:

val subscription: Subscription?

Use an explicit state:

sealed interface SubscriptionState {
    data object None : SubscriptionState

    data class Active(
        val plan: Plan,
        val renewalDate: RenewalDate
    ) : SubscriptionState

    data class Cancelled(
        val cancelledAt: CancelledAt
    ) : SubscriptionState
}

Then your model becomes:

data class User(
    val id: UserId,
    val name: UserName,
    val email: Email,
    val subscription: SubscriptionState
)

This avoids ambiguity:

subscription == null

could mean:

  • not loaded
  • user has no subscription
  • API forgot to send it
  • parsing failed
  • permission denied

A sealed class makes each state explicit.


3. Use sealed classes for loading/error states

Avoid UI or repository models like this:

data class UserScreenState(
    val user: User?,
    val isLoading: Boolean,
    val error: Throwable?
)

This allows invalid combinations:

user != null && isLoading == true && error != null

Instead:

sealed interface UserScreenState {
    data object Loading : UserScreenState

    data class Loaded(
        val user: User
    ) : UserScreenState

    data class Failed(
        val error: UserError
    ) : UserScreenState
}

Now impossible states are unrepresentable.

Usage:

fun render(state: UserScreenState) {
    when (state) {
        UserScreenState.Loading -> showLoading()

        is UserScreenState.Loaded -> showUser(state.user)

        is UserScreenState.Failed -> showError(state.error)
    }
}

No nullable checks needed.


4. Use Result wrappers for operations

For repository/service calls, avoid:

suspend fun getUser(id: String): User?

because null does not explain what happened.

Prefer:

suspend fun getUser(id: UserId): Result<User>

Usage:

val result = repository.getUser(userId)

result
    .onSuccess { user ->
        showUser(user)
    }
    .onFailure { throwable ->
        showError(throwable)
    }

However, Kotlin’s built-in Result<T> uses Throwable for failure. For richer domain errors, a custom result type is often better.


5. Prefer a custom domain Result for complex models

For complex systems, define your own result wrapper:

sealed interface AppResult<out T, out E> {
    data class Success<T>(
        val value: T
    ) : AppResult<T, Nothing>

    data class Failure<E>(
        val error: E
    ) : AppResult<Nothing, E>
}

Example domain errors:

sealed interface UserError {
    data object NotFound : UserError
    data object Unauthorized : UserError

    data class InvalidResponse(
        val reason: String
    ) : UserError

    data class NetworkFailure(
        val cause: Throwable
    ) : UserError
}

Repository:

interface UserRepository {
    suspend fun getUser(id: UserId): AppResult<User, UserError>
}

Usage:

when (val result = repository.getUser(userId)) {
    is AppResult.Success -> {
        val user = result.value
        showUser(user)
    }

    is AppResult.Failure -> {
        when (val error = result.error) {
            UserError.NotFound -> showNotFound()
            UserError.Unauthorized -> showUnauthorized()
            is UserError.InvalidResponse -> showInvalidResponse(error.reason)
            is UserError.NetworkFailure -> showNetworkError(error.cause)
        }
    }
}

This avoids both nullable success values and ambiguous failures.


6. Convert nullable DTOs at the boundary

External APIs, databases, and JSON often contain nullable fields. Keep that nullability in DTOs only.

Example DTO:

data class UserDto(
    val id: String?,
    val name: String?,
    val email: String?,
    val subscription: SubscriptionDto?
)

Then map to a safe domain model:

fun UserDto.toDomain(): AppResult<User, UserError> {
    val id = id ?: return AppResult.Failure(
        UserError.InvalidResponse("Missing user id")
    )

    val name = name ?: return AppResult.Failure(
        UserError.InvalidResponse("Missing user name")
    )

    val email = email ?: return AppResult.Failure(
        UserError.InvalidResponse("Missing user email")
    )

    return AppResult.Success(
        User(
            id = UserId(id),
            name = UserName(name),
            email = Email(email),
            subscription = subscription.toDomainState()
        )
    )
}

Subscription mapping:

fun SubscriptionDto?.toDomainState(): SubscriptionState {
    if (this == null) {
        return SubscriptionState.None
    }

    return when (status) {
        "active" -> SubscriptionState.Active(
            plan = Plan(planName),
            renewalDate = RenewalDate(renewalDate)
        )

        "cancelled" -> SubscriptionState.Cancelled(
            cancelledAt = CancelledAt(cancelledAt)
        )

        else -> SubscriptionState.None
    }
}

In stricter systems, unknown statuses should return an error instead of None.


7. Model “not loaded” separately from “empty”

A common mistake is using nullable fields for lazy or partial loading:

data class Profile(
    val user: User,
    val orders: List<Order>?
)

Does orders == null mean “not loaded”, “failed”, or “user has no orders”?

Use a sealed class:

sealed interface LoadState<out T> {
    data object NotLoaded : LoadState<Nothing>
    data object Loading : LoadState<Nothing>

    data class Loaded<T>(
        val value: T
    ) : LoadState<T>

    data class Failed(
        val error: DomainError
    ) : LoadState<Nothing>
}

Then:

data class Profile(
    val user: User,
    val orders: LoadState<List<Order>>
)

An empty list now means truly loaded and empty:

Profile(
    user = user,
    orders = LoadState.Loaded(emptyList())
)

8. Use domain-specific alternatives to nullable primitives

Instead of:

data class Product(
    val discountPercent: Int?
)

Use:

sealed interface Discount {
    data object None : Discount

    data class Percentage(
        val value: Int
    ) : Discount
}

Then:

data class Product(
    val id: ProductId,
    val price: Money,
    val discount: Discount
)

This is clearer than checking whether discountPercent is null.


9. Combine sealed classes and result wrappers

A good pattern is:

sealed interface DataState<out T, out E> {
    data object Idle : DataState<Nothing, Nothing>
    data object Loading : DataState<Nothing, Nothing>

    data class Success<T>(
        val value: T
    ) : DataState<T, Nothing>

    data class Failure<E>(
        val error: E
    ) : DataState<Nothing, E>
}

Example:

data class UserViewModelState(
    val user: DataState<User, UserError>
)

Rendering:

fun render(state: UserViewModelState) {
    when (val userState = state.user) {
        DataState.Idle -> showIdle()
        DataState.Loading -> showLoading()

        is DataState.Success -> {
            showUser(userState.value)
        }

        is DataState.Failure -> {
            showUserError(userState.error)
        }
    }
}

10. Practical rule of thumb

Use nullable types only when null has exactly one obvious meaning.

Nullable may be okay here:

val middleName: String?

because “person has no middle name” is often obvious.

But avoid nullable here:

val user: User?
val error: Throwable?
val status: String?
val payment: Payment?
val permissions: List<Permission>?

because these often have multiple possible meanings.


Recommended structure

// External layer
data class UserDto(
    val id: String?,
    val name: String?,
    val email: String?
)

// Domain layer
data class User(
    val id: UserId,
    val name: UserName,
    val email: Email
)

sealed interface UserError {
    data object NotFound : UserError
    data object Unauthorized : UserError
    data class InvalidResponse(val reason: String) : UserError
}

sealed interface AppResult<out T, out E> {
    data class Success<T>(val value: T) : AppResult<T, Nothing>
    data class Failure<E>(val error: E) : AppResult<Nothing, E>
}

// Mapping boundary
fun UserDto.toDomain(): AppResult<User, UserError> {
    val id = id ?: return AppResult.Failure(
        UserError.InvalidResponse("Missing id")
    )

    val name = name ?: return AppResult.Failure(
        UserError.InvalidResponse("Missing name")
    )

    val email = email ?: return AppResult.Failure(
        UserError.InvalidResponse("Missing email")
    )

    return AppResult.Success(
        User(
            id = UserId(id),
            name = UserName(name),
            email = Email(email)
        )
    )
}

Summary

To avoid nullable types in complex data models:

  • Keep nullable fields in DTOs, not domain models.
  • Convert DTOs into non-null domain models at boundaries.
  • Use sealed classes for meaningful states.
  • Use Result or custom AppResult<T, E> for success/failure.
  • Model loading, missing, empty, failed, and unauthorized as separate states.
  • Make invalid states impossible to represent.

The core idea is:

// Avoid
val user: User?
val error: Throwable?

// Prefer
sealed interface UserState {
    data object Loading : UserState
    data class Loaded(val user: User) : UserState
    data class Failed(val error: UserError) : UserState
}