- notmuch_rb_thread_t *thread;
- notmuch_rb_threads_t *threads;
- VALUE threadv;
-
- Data_Get_Struct(self, notmuch_rb_threads_t, threads);
- if (!threads->nm_threads)
- return self;
-
- for (; notmuch_threads_valid(threads->nm_threads);
- notmuch_threads_move_to_next(threads->nm_threads))
- {
- threadv = Data_Make_Struct(notmuch_rb_cThread, notmuch_rb_thread_t,
- notmuch_rb_thread_mark, notmuch_rb_thread_free, thread);
- thread->nm_thread = notmuch_threads_get(threads->nm_threads);
- thread->threads = self;
- rb_yield(threadv);
+ notmuch_thread_t *thread;
+ notmuch_threads_t *threads;
+
+ Data_Get_Notmuch_Threads (self, threads);
+
+ for (; notmuch_threads_valid (threads); notmuch_threads_move_to_next (threads)) {
+ thread = notmuch_threads_get (threads);
+ rb_yield (Data_Wrap_Struct (notmuch_rb_cThread, NULL, NULL, thread));