1 package com.github.davidmoten.rx.jdbc;
2
3 import java.sql.Connection;
4 import java.sql.PreparedStatement;
5 import java.sql.ResultSet;
6 import java.util.concurrent.atomic.AtomicBoolean;
7
8 class State {
9 volatile Connection con;
10 volatile PreparedStatement ps;
11 volatile ResultSet rs;
12 final AtomicBoolean closed = new AtomicBoolean(false);
13 }